TCP/UDP协议的Socket编程（Java语言）

TCP使用Socket进行网络通信的过程：

服务器程序将一个套接字绑定到一个特定的端口，并通过此套接字等待和监听来自客户端的连接请求；

客户端根据服务器所在的主机名和端口向服务器发送连接请求；

如果一切正常，服务器接收连接请求，并获得一个新的绑定到不同端口地址的套接字；

客户端和服务器通过读写套接字进行通讯。

UDP使用Socket进行网络通信的过程

UDP协议通信没有客户端（浏览器）/服务器模式，通信的双方是平等的;

每个UDP建立都有独立的端口号绑定。编程时对独立的一个端点编程，使其同时具有发送接收的方法;

与TCP协议编程不同，UDP收发数据不用I/O流。

基于TCP协议的Socket编程

TCP服务端：

1. 创建一个ServerSocket对象；

2. 调用accept()方法接收客户端请求；

3. 从Socket中获取I/0流；

4. 对I/0进行读写操作，完成与客户端的交互。

TCP客户端：

1. 创建一个Socket对象；

2. 从Socket中获取I/0流；

4. 对I/0进行读写操作，完成与客户端的交互；

5. 关闭I/O流和Socket。



服务器编程：接收客户端传来的字节流，转化成字符流，再转化成大写，传回服务器。

import java.net.ServerSocket;
public class TCPServer{
public static void main(String[] args){
//1.创建一个ServerSocket对象
ServerSocket serverSocket=new ServerSocket(8888);
//2.调用accept()方法来接受客户端请求
Socket socket=serverSocket.accept();
System.out.println(socket.getInetAddress().getHostAddress()+"has connected");//表示某台网络设备与服务器连接成功
//3.从Socket对象中获取I/0流；
BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
'''BufferedWriter bw=new BufferedWriter(new OutputSreamWriter(socket.getOutputStram()));'''
//自动刷新缓冲区
PrintWriter pw=new PrintWriter(socket.getOutputStream().true);
//把客户端传过来的字节流转换成字符流
String line=null;
while(line=br.readline()!=null){
if(line.equals("over")){
break;
}
System.out.println(line);
'''''
bw.write(line.toUpperCase());//把转换成大写的字符串传给客户端。
bw.newLine();//换行，标志着一段字符输入完毕，客户端readLine才会确认输入完毕
bw.flush();//清空缓冲区
'''''
pw.println(line.toUpperCase());

}
//释放资源
'''bw.close();'''
pw.close();
br.close();
socket.close();
System.out.println(socket.getInetAddress().getHostAddress()+"has disconnected");//表示某台网络设备与服务器连接断开
}
}

客户端编程：客户端传输键盘输入给服务器，再读取从服务器传回的大写字符串

import java.net.Socket;
public class TCPClient{
public static void main(String[] args) throws IOExceprion{
//1.创建一个Socket对象；
Socket socket=new Socket("127.0.0.1",8888);
//读取键盘输入的字节流
BufferedReader br=new BufferedReader(new InputStramReader(System.in));
//对I/0进行读写操作，完成与客户端的交互；
//把键盘输入的字节流存入socket的buffer中向服务器发送
BufferedWriter bw=new BufferedWriter(new OutputSreamWriter(socket.getOutputStram()));
//从socket的buffer中读取服务器传来的字节流
BufferedReader reader=new BufferedReader(new InputStreamReader(socket.getInputStream()));
while(true){
String line=br.readLine();//从键盘不断输入的字符串
bw.write(line);
bw.newLine();//换行，标志着一段字符输入完毕，服务端readLine才会确认输入完毕
bw.flush;
if(line.equals("over")){
break;
}
//读取从服务端传来的字符
System.out.println(reader.readline());
}
//释放资源
reader.close();
br.close();
bw.close();
socket.close();
}
}

执行：分别打开两个DOS窗口，第一个先运行服务器程序，第二个运行客户端程序

基于UDP协议的Socket编程

创建发送端

1. 建立DatagramSocket对象，该端点建立，系统会随机分配一个端口，也可以手动指定；

2. 将数据进行packet包的封装，必须要指定目的地址和端口；

3. 通过socket服务的send方法将该包发出；

4. 将socket 关闭。

创建接收端

1. 建立DatagramSocket对象，要监听一个端口；

2. 通过socket的receive方法将获取数据包；

3. 通过数据包dp的方法 getData()、getAddress()、getPort()等方法，获取包中的信息；

4. 将socket关闭。



UDP端点编程：

发送端

import java.net InetAddress;
import java.net DatagramSocket;
import java.net DatagramPacket;

public class UDPDemo1{
public static void main(String[] args) throw IOException{
//1. 建立DatagramSocket对象，该端点建立，系统会随机分配一个端口；
DatagramSocket socket=new DatagramSocket();
//2. 发送数据，将数据进行packet包的封装，必须要指定目的地址和端口；
String str="I love studying";
DatagramPacket packet=new DatagramPacket(str.getBytes(),str.length,InetAddress.getByName("localhost"),8000);
//参数列表：【发送数据】【发送数据的长度】【接收端主机的地址】【接收端口号】
//3. 通过socket服务的send方法将该包发出；
socket.send(packet);
//4. 通过socket的receive方法将获取数据包，存入一个数组；
byte[] buff=new byte[100];
DatagramPacket packet2=new DatagramPacket(buff,100);
socket.receive(packet2);
//5.通过数据包dp的方法 getData()把接受的字节数组转换成字符串
System.out.println(new String(packet2.getData()));
//6. 将socket 关闭
socket.close();
}
}

接收端

import java.net InetAddress;
import java.net DatagramSocket;
import java.net DatagramPacket;

public class UDPDemo2{
public static void main(String[] args) throw IOException {
//1. 建立DatagramSocket对象，该端点建立，手动指定端口；
DatagramSocket socket=new DatagramSocket(8000);
//2. 通过socket的receive方法将获取数据包，存入一个数组；
byte[] buff=new byte[100];
'''''
DatagramPacket packet=new DatagramPacket(buff,100);
//当接收字符长度不够100时会出现多余的字符
'''''
DatagramPacket packet=new DatagramPacket(buff,0,packet.getLength());

socket.receive(packet);
//3.通过数据包dp的方法 getData()把接受的字节数组转换成字符串
System.out.println(new String(packet.getData()));
//4. 发送数据，将数据进行packet包的封装，必须要指定目的地址和端口；
String str="Study makes my happy！";
DatagramPacket packet2=new DatagramPacket(str.getBytes(),str.length,packet.getAddress(),packet.getPort());
//【接收端主机的地址】【接收端口号】可以根据之前接收到的packet获取
//5. 通过socket服务的send方法将该包发出；
socket.send(packet2);
//6. 将socket 关闭
socket.close();
}
}