javatcp接收數據

1. 使用java網路編程編寫SIP消息的收發，TCP和UDP有什麼區別

TCP---傳輸控制協議,提供的是面向連接、可靠的位元組流服務。當客戶和伺服器彼此交換數據前，必須先在雙方之間建立一個TCP連接，之後才能傳輸數據。TCP提供超時重發，丟棄重復數據，檢驗數據，流量控制等功能，保證數據能從一端傳到另一端。
UDP---用戶數據報協議，是一個簡單的面向數據報的運輸層協議。UDP不提供可靠性，它只是把應用程序傳給IP層的數據報發送出去，但是並不能保證它們能到達目的地。由於UDP在傳輸數據報前不用在客戶和伺服器之間建立一個連接，且沒有超時重發等機制，故而傳輸速度很快

UDP
UDP 與 TCP 的主要區別在於 UDP 不一定提供可靠的數據傳輸。事實上，該協議不能保證數據准確無誤地到達目的地。UDP 在許多方面非常有效。當某個程序的目標是盡快地傳輸盡可能多的信息時（其中任意給定數據的重要性相對較低），可使用 UDP。ICQ 短消息使用 UDP 協議發送消息。
許多程序將使用單獨的TCP連接和單獨的UDP連接。重要的狀態信息隨可靠的TCP連接發送，而主數據流通過UDP發送。

TCP
TCP的目的是提供可靠的數據傳輸，並在相互進行通信的設備或服務之間保持一個虛擬連接。TCP在數據包接收無序、丟失或在交付期間被破壞時，負責數據恢復。它通過為其發送的每個數據包提供一個序號來完成此恢復。記住，較低的網路層會將每個數據包視為一個獨立的單元，因此，數據包可以沿完全不同的路徑發送，即使它們都是同一消息的組成部分。這種路由與網路層處理分段和重新組裝數據包的方式非常相似，只是級別更高而已。
為確保正確地接收數據，TCP要求在目標計算機成功收到數據時發回一個確認（即 ACK）。如果在某個時限內未收到相應的 ACK，將重新傳送數據包。如果網路擁塞，這種重新傳送將導致發送的數據包重復。但是，接收計算機可使用數據包的序號來確定它是否為重復數據包，並在必要時丟棄它。

TCP與UDP的選擇

如果比較UDP包和TCP包的結構，很明顯UDP包不具備TCP包復雜的可靠性與控制機制。與TCP協議相同，UDP的源埠數和目的埠數也都支持一台主機上的多個應用。一個16位的UDP包包含了一個位元組長的頭部和數據的長度，校驗碼域使其可以進行整體校驗。（許多應用只支持UDP，如：多媒體數據流，不產生任何額外的數據，即使知道有破壞的包也不進行重發。）
很明顯，當數據傳輸的性能必須讓位於數據傳輸的完整性、可控制性和可靠性時，TCP協議是當然的選擇。當強調傳輸性能而不是傳輸的完整性時，如：音頻和多媒體應用，UDP是最好的選擇。在數據傳輸時間很短，以至於此前的連接過程成為整個流量主體的情況下，UDP也是一個好的選擇，如：DNS交換。把SNMP建立在UDP上的部分原因是設計者認為當發生網路阻塞時，UDP較低的開銷使其有更好的機會去傳送管理數據。TCP豐富的功能有時會導致不可預料的性能低下，但是我們相信在不遠的將來，TCP可靠的點對點連接將會用於絕大多數的網路應用。

2. TCP/IP協議 怎麼用JAVA發送和接收二進制數據 要具體實例

1.TCP/IP協議要求信息必須在塊（chunk）中發送和接收，而塊的長度必須是8位的倍數，因此，我們可以認為TCP/IP協議中傳輸的信息是位元組序列。如何發送和解析信息需要一定的應用程序協議。

2.信息編碼：

首先是Java里對基本整型的處理，發送時，要注意：1）每種數據類型的位元組個數；2）這些位元組的發送順序是怎樣的？（little-endian還是
big-endian）；3）所傳輸的數值是有符號的（signed）還是無符號的（unsigned）。具體編碼時採用位操作（移位和屏蔽）就可以了。
具體在Java里，可以採用DataOutputStream類和ByteArrayOutputStream來實現。恢復時可以採用
DataInputStream類和ByteArrayInputStream類。

其次，字元串和文本，在一組符號與一組整數之間的映射稱為編碼字元集（coded character
set）。發送者與接收者必須在符號與整數的映射方式上達成共識，才能使用文本信息進行通信，最簡單的方法就是定義一個標准字元集。具體編碼時採用
String的getBytes()方法。

最後，位操作。如果設置一個特定的設為1，先設置好掩碼(mask)，之後用或操作；要清空特定一位，用與操作。

3.成幀與解析

成幀（framing）技術解決了接收端如何定位消息的首位位置的問題。

如果接收者試圖從套接字中讀取比消息本身更多的位元組，將可能發生以下兩種情況之一：如果信道中沒有其他消息，接收者將阻塞等待，同時無法處理接收
到的消息；如果發送者也在等待接收端的響應消息，則會形成死鎖（dealock）；另一方面，如果信道中還有其他消息，則接收者會將後面消息的一部分甚至
全部讀到第一條消息中去，這將產生一些協議錯誤。因此，在使用TCP套接字時，成幀就是一個非常重要的考慮因素。

有兩個技術：

1.基於定界符（Delimiter-based）：消息的結束由一個唯一的標記（unique
marker）指出，即發送者在傳輸完數據後顯式添加的一個特殊位元組序列。這個特殊標記不能在傳輸的數據中出現。幸運的是，填充（stuffing）技術
能夠對消息中出現的定界符進行修改，從而使接收者不將其識別為定界符。在接收者掃描定界符時，還能識別出修改過的數據，並在輸出消息中對其進行還原，從而
使其與原始消息一致。

2.顯式長度（Explicit length）：在變長欄位或消息前附加一個固定大小的欄位，用來指示該欄位或消息中包含了多少位元組。這種方法要確定消息長度的上限，以確定保存這個長度需要的位元組數。

介面：

Java代碼 import java.io.IOException; import java.io.OutputStream; public interface Framer { void frameMsg(byte [] message,OutputStream out) throws IOException; byte [] nextMsg() throws IOException; }
定界符的方式：

Java代碼 import java.io.ByteArrayOutputStream; import java.io.EOFException; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; public class DelimFramer implements Framer { private InputStream in;//data source; private static final byte DELIMTER=(byte)'\n';//message delimiter public DelimFramer(InputStream in){ this.in=in; } @Override public void frameMsg(byte[] message, OutputStream out) throws IOException { //ensure that the message dose not contain the delimiter for(byte b:message){ if(b==DELIMTER) throw new IOException("Message contains delimiter"); } out.write(message); out.write(DELIMTER); out.flush(); } @Override public byte[] nextMsg() throws IOException { ByteArrayOutputStream messageBuffer=new ByteArrayOutputStream(); int nextByte; while((nextByte=in.read())!=DELIMTER){ if(nextByte==-1){//end of stream? if(messageBuffer.size()==0){ return null; }else{ throw new EOFException("Non-empty message without delimiter"); } } messageBuffer.write(nextByte); } return messageBuffer.toByteArray(); } }
顯式長度方法：

Java代碼 import java.io.DataInputStream; import java.io.EOFException; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; public class LengthFramer implements Framer { public static final int MAXMESSAGELENGTH=65535; public static final int BYTEMASK=0xff; public static final int SHOTMASK=0xffff; public static final int BYTESHIFT=8; private DataInputStream in;// wrapper for data I/O public LengthFramer(InputStream in) throws IOException{ this.in=new DataInputStream(in); } @Override public void frameMsg(byte[] message, OutputStream out) throws IOException { if(message.length>MAXMESSAGELENGTH){ throw new IOException("message too long"); } //write length prefix out.write((message.length>>BYTEMASK)&BYTEMASK); out.write(message.length&BYTEMASK); //write message out.write(message); out.flush(); } @Override public byte[] nextMsg() throws IOException { int length; try{ length=in.readUnsignedShort(); }catch(EOFException e){ //no (or 1 byte) message; return null; } //0<=length<=65535; byte [] msg=new byte[length]; in.readFully(msg);//if exception,it's a framing error; return msg; } }

3. 在Java中實現TCP協議編程中怎麼傳

在Java中實現TCP協議編程

ServerSocket：編寫TCP網路服務程序,首先要用到java.net.ServerSocket類用以創建伺服器Socket

構造方法：

ServerSocket(intport)：創建綁定到特定埠的伺服器套接字

ServerSocket(intport,intbacklog)：利用指定的backlog(伺服器忙時保持連接請求的等待客戶數量),創建伺服器套接字並將其綁定到指定的本地埠號。

ServerSocket(intport,intbacklog,InetAddressbindAddr)：使用指定的埠、偵聽backlog和要綁定到的本地IP地址創建伺服器。

Socket：客戶端要與伺服器建立連接,必須先創建一個Socket對象

常用構造方法

Socket(Stringhost,intport)：創建一個流套接字並將其連接到指定主機上的指定埠號。

Socket(InetAddressaddress,intport)：創建一個流套接字並將其連接到指定IP地址的指定埠號。

伺服器端程序調用ServerSocket類中的accept()方法等待客戶端的連接請求，一旦accept()接收了客戶端連接請求，該方法返回一個與該客戶端建立了專線連接的Socket對象，不用程序去創建這個Socket對象。建立了連接的兩個Socket是以IO流的方式進行數據交換的，Java提供了Socket類中的getInputStream()返回Socket的輸入流對象，getOutputStream()返回Socket的輸出流對象。

TCP伺服器與TCP客戶端間的數據的接受圖示：

用TCP實現伺服器與客戶端的「聊天」：

實例代碼：

客戶端：

packagecom.hbsi.net;

importjava.net.Socket;

importjava.io.*;

publicclassTcpClient{

publicstaticvoidmain(String[]args)throwsException{

//1.建立tcp客戶端socket，要確定要連接的伺服器ip，port

Sockets=newSocket("192.168.49.87",9009);

//獲取鍵盤錄入

BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in));

//2.通過建立的socket，獲取輸出流對象

//數據輸出給伺服器端

OutputStreamout=s.getOutputStream();

BufferedWriterbwout=newBufferedWriter(newOutputStreamWriter(out));

//獲取伺服器端返回的數據

//讀取伺服器端發過來的信息InputStreamReader()

BufferedReaderbrin=newBufferedReader(newInputStreamReader(

s.getInputStream()));

Stringline=null;

while((line=br.readLine())!=null){

if(line.equals("over"))

break;

bwout.write(line);

bwout.newLine();

bwout.flush();

Stringstr=brin.readLine();

System.out.println("server:"+str);

}

br.close();

s.close();

}

}

伺服器端：

packagecom.hbsi.net;

importjava.io.BufferedReader;

importjava.io.BufferedWriter;

importjava.io.InputStream;

importjava.io.InputStreamReader;

importjava.io.OutputStreamWriter;

importjava.net.ServerSocket;

importjava.net.Socket;

publicclassTcpServer{

publicstaticvoidmain(String[]args)throwsException{

//1.建立伺服器socket

ServerSocketss=newServerSocket(9009);

//2.調用accept()

Sockets=ss.accept();

System.out.println(s.getInetAddress().getHostAddress()

+"...connection");

//讀取客戶的信息的輸入流

InputStreamin=s.getInputStream();

BufferedReaderbrin=newBufferedReader(newInputStreamReader(in));

//向客戶端發送信息輸出流，服務端向客戶端返回信息OutputStreamWriter()

BufferedWriterbrout=newBufferedWriter(newOutputStreamWriter(

s.getOutputStream())); Stringline=null;

while((line=brin.readLine())!=null){

System.out.println("client:"+line);

brout.write(line.toUpperCase());//伺服器端收到信息後，將信息轉為大寫返回給客戶端toUpperCase()

brout.newLine();

brout.flush();

}

s.close();

ss.close();

}

}