java网络编程基础，Socket的发送与接收，javaTCP，UDP协议的实现。Socket(套接字)_java发送socket请求

java网络编程基础，Socket的发送与接收，TCP，UDP通信的实现

---

前言

Socket(套接字)
• 用于描述IP地址和端口，是一个通信链的句柄。在Internet上的主机一般运行了多个服务软件，同时提供几种服务。每种服务都打开一个Socket，并绑定到一个端口上，不同的端口对应于不同的服务。
• Socket就是为网络编程提供的一种机制；通信的两端都有Socket；网络通信其实就是Socket间的通信；数据在两个Socket间通过IO传输。

协议
• UDP协议
– 将数据源和目的封装成数据包中，不需要建立连接；每个数据报的大小在限制在64k；因无连接，是不可靠协议；不需要建立连接，速度快
• TCP协议
– 建立连接，形成传输数据的通道；在连接中进行大数据量传输；通过三次握手完成连接，是可靠协议；必须建立连接，效率会稍低

---

一、UDP协议传输

• DatagramSocket(创建Socket对象)与DatagramPacket(数据报包)
• 建立发送端，接收端。
• 建立数据包。
• 调用Socket的发送接收方法。
• 关闭Socket。 • 发送端与接收端是两个独立的运行程序。

二、UDP使用步骤

1.使用UDP协议发送数据（发送数据包）

创建发送端Socket对象
创建数据并打包
发送数据
释放资源

• DatagramSocket:此类表示用来发送和接收数据，基于UDP协议
• DatagramSocket():创建Socket对象并随机分配端口号
• DatagramSocket(int port):创建Socket对象并指定端口号

public static void main(String[] args) throws IOException {
        //创建发送端Socket对象
        DatagramSocket ds = new DatagramSocket();
        //创建数据并打包
        //DatagramPacket：此类表示数据报包
        //数据byte[]
        //设备的地址 ip
        //进程的地址 端口号
        //DatagramPacket(byte[] buf, int length, InetAddress address, int port)
        String s = "Hello,UDP!";
        byte[] bys = s.getBytes();
        int length = bys.length;
        InetAddress address = InetAddress.getByName("127.0.0.1");
        int port = 12345;
        //打包
        DatagramPacket dp = new DatagramPacket(bys,length,address,port);
        //发送数据
        ds.send(dp);
        //释放资源
        ds.close();

        System.out.println("发送完毕");
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

2.使用UDP协议接收数据

创建接收端Socket对象
接收数据
解析数据
输出数据
释放资源

public static void main(String[] args) throws IOException {
        //创建接收端Socket对象；与发送消息的端口一致
        DatagramSocket ds = new DatagramSocket(12345);
        //接收数据
        //DatagramPacket(byte[] buf, int length)
        byte[] bys = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bys,bys.length);
        System.out.println(1);
        ds.receive(dp);			//阻塞
        System.out.println(2);
        //解析数据
        //InetAddress getAddress()  发送端的ip对象
        InetAddress address = dp.getAddress();
        //byte[] getData()  获取接收到的数据，也可以直接使用创建包对象时的数组
        byte[] data = dp.getData();
        //int getLength()   获取收取到的数据长度
        int length = dp.getLength();
        //输出数据
        System.out.println("发送者:"+address);
        System.out.println("数据:"+new String(data,0,length));
        System.out.println("数据:"+new String(bys,0,length));
        //释放资源
        ds.close();

        System.out.println("接收完毕");
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

三、TCP协议传输

Socket和ServerSocket（服务端）
建立客户端和服务器端
建立连接后，通过Socket中的IO流进行数据的传输
关闭socket
同样，客户端与服务器端是两个独立的应用程序

四、TCP使用步骤

1.建立服务器端，使用TCP协议接收数据

创建接收端Socket对象
监听（阻塞）
获取输入流对象
获取数据
输出数据
释放资源

• ServerSocket 接收端，服务端
• ServerSocket(int port)

public static void main(String[] args) throws IOException {
		//创建接收端Socket对象
		ServerSocket serverSocket = new ServerSocket(10086); 
		while(true) {
			//监听（阻塞）
			Socket socket = serverSocket.accept();
			//获取输入流对象
			InputStream is = socket.getInputStream();
			//获取数据
			byte[] bys = new byte[1024];
			int len;	//用于存储读到的字节个数
			len = is.read(bys);
			//输出数据
			InetAddress inetAdress = socket.getInetAddress();
			System.out.println(inetAdress.getHostName());
			System.out.println(new String(bys,0,len));

			//释放资源
			is.close();
			socket.close();
			//serverSocket.close();
		}
	}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

2.建立客户端，使用TCP协议发送数据

创建发送端Socket对象（创建连接）
获取输出流对象
发送数据
释放资源

• Socket(InetAddress address, int port)

public static void main(String[] args) throws IOException {
		//创建发送端Socket对象（创建连接）
		Socket socket = new Socket(InetAddress.getByName("127.0.0.1"),10086);
		//获取输出流对象
		OutputStream os = socket.getOutputStream();
		//发送数据
		String str = "Hi,TCP!";
		os.write(str.getBytes());
		//释放资源
		//os.close();
		socket.close();
	}
1
2
3
4
5
6
7
8
9
10
11
12

五、使用TCP协议发送数据，并将接收到的数据转换成大写返回

客户端发出数据
服务端接收数据
服务端转换数据
服务端发出数据
客户端接收数据

1.建立客户端

public static void main(String[] args) throws IOException {
		//创建发送端Socket对象（创建连接）
		Socket socket = new Socket(InetAddress.getByName("127.0.0.1"),10086);
		//获取输出流对象
		OutputStream os = socket.getOutputStream();
		//发送数据
		String str = "tcp,hello!";
		os.write(str.getBytes());
		
		//接收数据
		InputStream is = socket.getInputStream();
		byte[] bys = new byte[1024];
		int len;	//用于存储读到的字节个数
		len = is.read(bys);
		//输出数据
		System.out.println(new String(bys,0,len));	
		//释放资源
		socket.close();
	}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

2.建立服务器端

public static void main(String[] args) throws IOException {
		//创建接收端Socket对象
		ServerSocket serverSocket = new ServerSocket(10086); 
		while(true) {
			//监听（阻塞）
			Socket socket = serverSocket.accept();
			//获取输入流对象
			InputStream is = socket.getInputStream();
			//获取数据
			byte[] bys = new byte[1024];
			int len;	//用于存储读到的字节个数
			len = is.read(bys);
			//输出数据
			String str = new String(bys,0,len);
			System.out.println(str);
			//转换数据
			String upperStr = str.toUpperCase();
			//获取输出流对象
			OutputStream os = socket.getOutputStream();
			//返回数据（发出数据）
			os.write(upperStr.getBytes());
			//释放资源
			is.close();
			socket.close();
		}
		//serverSocket.close();
	}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

---

总结

UDP协议是通过数据包直接发送，不需要建立连接。
DatagramSocket:此类表示用来发送和接收数据，基于UDP协议。
DatagramPacket： DatagramPacket(bys,length,address,port);数据报包，包含了数据byte[]、长度、设备的地址ip、端口号

DatagramSocket ds = new DatagramSocket();
DatagramPacket dp = new DatagramPacket(bys,length,address,12345);
ds.send(dp);				//完成发送
1
2
3

DatagramPacket(byte[] buf, int length);数据报包，包含了数据byte[]、长度

DatagramSocket ds = new DatagramSocket(12345);//创建接收端Socket对象；与发送消息的端口一致
ds.receive(dp);			//阻塞
DatagramPacket dp = new DatagramPacket(bys,bys.length);
//解析数据
InetAddress address = dp.getAddress();	//InetAddress getAddress()  发送端的ip对象
byte[] data = dp.getData();	//byte[] getData()  获取接收到的数据，也可以直接使用创建包对象时的数组
int length = dp.getLength();  //int getLength()   获取收取到的数据长度
1
2
3
4
5
6
7

TCP协议是通过IO流直接发送，需要建立三次握手连接，所以需要先开启服务器端。分Socket和ServerSocket（服务端）

//创建发送端Socket对象（创建连接）
Socket socket = new Socket(InetAddress.getByName("127.0.0.1"),10086);
//获取输出流对象
OutputStream os = socket.getOutputStream();
//发送数据
String str = "Hi,TCP!";
os.write(str.getBytes());
1
2
3
4
5
6
7

//创建接收端Socket对象
ServerSocket serverSocket = new ServerSocket(10086); 
while(true) {
			Socket socket = serverSocket.accept();//监听（阻塞）
			InputStream is = socket.getInputStream();//获取输入流对象
			//获取数据
			byte[] bys = new byte[1024];
			int len;	//用于存储读到的字节个数
			len = is.read(bys);
			//输出数据
			InetAddress inetAdress = socket.getInetAddress();
			System.out.println(inetAdress.getHostName());
			System.out.println(new String(bys,0,len));
			//释放资源
			is.close();
			socket.close();
			//serverSocket.close();
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

还有记得是释放资源。