java中TCP/UDP详细总结
TCP/UDP:TCP主要是面向连接的协议,它包含有建立和拆除连接,保证数据流的顺序和正确性等功能。
每次对TCP中间的数据操作相当于对一个数据流进行访问。它最典型的特征就是那三次握手的建立连接过程。Server端所要做的事情主要是建立一个通信的端点,然后等待客户端发送的请求。典型的处理步骤如下:
1.构建一个ServerSocket实例,指定本地的端口。这个socket就是用来监听指定端口的连接请求的。
2.重复如下几个步骤:
a.调用socket的accept()方法来获得下面客户端的连接请求。通过accept()方法返回的socket实例,建立了一个和客户端的新连接。
b.通过这个返回的socket实例获取InputStream和OutputStream,可以通过这两个stream来分别读和写数据。
c.结束的时候调用socket实例的close()方法关闭socket连接。
TCP服务器端:
publicclassTCPServer{
publicstaticvoidmain(String[]args){
try{
ServerSocketserver=newServerSocket();
SocketAddressaddress=newInetSocketAddress(InetAddress.getLocalHost(),10001);
server.bind(address);
System.out.println("等待连接客户端...");
Socketclient=server.accept();
System.out.println("connectedwith"+client.getRemoteSocketAddress());
PrintWritersocketOut=newPrintWriter(client.getOutputStream());
System.out.println("等待客户端的消息...");
bytebuf[]=newbyte[1024];
if(client.getInputStream().read(buf)>0){
System.out.println("收到的消息:"+newString(buf));
}
System.out.println("发送消息给客户端...");
StringsendStr="服务器返回的信息";
socketOut.write(sendStr);
socketOut.flush();
socketOut.close();
client.close();
server.close();
}catch(IOExceptione){
System.out.println(e.getMessage());
e.printStackTrace();
}
}
}
TCP客户端:
1.构建Socket实例,通过指定的远程服务器地址和端口来建立连接。
2.通过Socket实例包含的InputStream和OutputStream来进行数据的读写。
3.操作结束后调用socket实例的close方法,关闭。
publicclassTCPClient{
publicstaticvoidmain(String[]args){
try{
finalSocketsocket=newSocket();
SocketAddressaddress=newInetSocketAddress(InetAddress.getLocalHost(),10001);
System.out.println("连接服务端...");
socket.connect(address);
PrintWritersocketOut=newPrintWriter(socket.getOutputStream());
BufferedReadersocketIn=newBufferedReader(
newInputStreamReader(socket.getInputStream()));
StringsendStr="客户端发送的消息";
System.out.println("发送消息给服务端...");
socketOut.write(sendStr);
socketOut.flush();
System.out.println("等待服务端的消息...");
StringreceiveStr=socketIn.readLine();
System.out.println("收到的消息:"+receiveStr);
socketOut.close();
socketIn.close();
socket.close();
}catch(IOExceptione){
System.out.println(e.getMessage());
e.printStackTrace();
}
}
}
UDP(UserDatagramProtocol,用户数据报协议)
UDP和TCP有两个典型的区别,一个就是它不需要建立连接,另外就是它在每次收发的报文都保留了消息的边界。
因为UDP协议不需要建立连接,它的过程如下:
1.构造DatagramSocket实例,指定本地端口。
2.通过DatagramSocket实例的receive方法接收DatagramPacket.DatagramPacket中间就包含了通信的内容。
3.通过DatagramSocket的send和receive方法来收和发DatagramPacket.
publicclassUDPServer{
publicstaticvoidmain(Stringargs[]){
DatagramSocketsocket=null;
DatagramPacketdatapacket=null;
InetSocketAddressaddress=null;
try{
address=newInetSocketAddress(InetAddress.getLocalHost(),7778);
socket=newDatagramSocket(address);
//socket.bind(address);
bytebuf[]=newbyte[1024];
datapacket=newDatagramPacket(buf,buf.length);
System.out.println("blockforreceivemessages...");
socket.receive(datapacket);
buf=datapacket.getData();
InetAddressaddr=datapacket.getAddress();
intport=datapacket.getPort();
System.out.println("MessageContent:"+newString(buf));
System.out.println("ReceiveFrom"+addr+":"+port);
SocketAddresstoAddress=datapacket.getSocketAddress();
StringsendStr="I'mServer,thisisthemessageforclient.";
buf=sendStr.getBytes();
datapacket=newDatagramPacket(buf,buf.length);
datapacket.setSocketAddress(toAddress);
socket.send(datapacket);
System.out.println("messagesended");
//释放资源
socket.close();
}catch(UnknownHostExceptione){
e.printStackTrace();
}catch(SocketExceptione){
e.printStackTrace();
}catch(IOExceptione){
e.printStackTrace();
}
}
}
UDP客户端的步骤也比较简单,主要包括下面3步:
1.构造DatagramSocket实例。
2.通过DatagramSocket实例的send和receive方法发送DatagramPacket报文。
3.结束后,调用DatagramSocket的close方法关闭。
因为和TCP不同,UDP发送报文的时候可以在同一个本地端口随意发送给不同的服务器,一般不需要在UDP的DatagramSocket的构造函数中指定目的服务器的地址。
另外,UDP客户端还有一个重要的不同就是,TCP客户端发送echo连接消息之后会在调用read方法的时候进入阻塞状态,而UDP这样却不行。因为UDP中间是可以允许报文丢失的。如果报文丢失了,进程一直在阻塞或者挂起的状态,则进程会永远没法往下走了。
所以会一般设置一个setSoTimeout方法,指定在多久的时间内没有收到报文就放弃。也可以通过指定一个数字,循环指定的次数来读取报文,读到就返回,否则就放弃。
publicclassUDPClient{
publicstaticvoidmain(Stringargs[]){
try{
DatagramSocketgetSocket=newDatagramSocket();
DatagramPacketdatapacket=null;
InetSocketAddresstoAddress=newInetSocketAddress(InetAddress.getLocalHost(),7778);
StringsendStr="I'mclient,thisisthemessageforserver.";
bytebuf[]=sendStr.getBytes();
datapacket=newDatagramPacket(buf,buf.length);
datapacket.setSocketAddress(toAddress);
getSocket.send(datapacket);
System.out.println("messagesended");
System.out.println("blockforreceivemessages...");
getSocket.receive(datapacket);
buf=datapacket.getData();
System.out.println("MessageContent:"+newString(buf));
getSocket.close();
}catch(SocketExceptione){
e.printStackTrace();
}catch(UnknownHostExceptione){
e.printStackTrace();
}catch(IOExceptione){
e.printStackTrace();
}
}
}
以上内容,需要的朋友可以参考