Socket通信基本示例

阳光穿透心脏的1/2处 2022-06-01 09:54 207阅读 0赞

一、搭建服务器端  
a)、创建ServerSocket对象绑定监听端口。  
b)、通过accept()方法监听客户端的请求。  
c)、建立连接后，通过输入流读取客户端发送的请求信息。  
d)、通过输出流向客户端发送请求信息。  
e)、关闭相关资源。

public class SocketServerOne {
    	public static void main(String[] args) throws Exception {
    		// 监听指定的端口
    		int port = 55533;
    		ServerSocket server = new ServerSocket(port);
    
    
    		// server将一直等待连接的到来
    		System.out.println("server将一直等待连接的到来");
    		Socket socket = server.accept();
    		// 建立好连接后，从socket中获取输入流，并建立缓冲区进行读取
    		InputStream inputStream = socket.getInputStream();
    		byte[] bytes = new byte[1024];
    		int len;
    		StringBuilder sb = new StringBuilder();
    		// 只有当客户端关闭它的输出流的时候，服务端才能取得结尾的-1
    		while ((len = inputStream.read(bytes)) != -1) {
    			// 注意指定编码格式，发送方和接收方一定要统一，建议使用UTF-8
    			sb.append(new String(bytes, 0, len, "UTF-8"));
    		}
    		System.out.println("get message from client: " + sb);
    
    
    		OutputStream outputStream = socket.getOutputStream();
    		outputStream.write("Hello Client,I get the message.".getBytes("UTF-8"));
    
    
    		inputStream.close();
    		outputStream.close();
    		socket.close();
    		server.close();
    	}
    }

二、搭建客户器端

a)、创建Socket对象，指明需要连接的服务器的地址和端口。  
b)、建立连接后，通过输出流向服务器发送请求信息。  
c)、通过输入流获取服务器的响应信息。  
d)、关闭响应资源。

public class SocketClientOne {
    	public static void main(String args[]) throws Exception {
    		// 要连接的服务端IP地址和端口
    		String host = "127.0.0.1";
    		int port = 55533;
    		// 与服务端建立连接
    		Socket socket = new Socket(host, port);
    		// 建立连接后获得输出流
    		OutputStream outputStream = socket.getOutputStream();
    		String message = "你好，明天";
    		socket.getOutputStream().write(message.getBytes("UTF-8"));
    		// 通过shutdownOutput高速服务器已经发送完数据，后续只能接受数据
    		socket.shutdownOutput();
    
    
    		InputStream inputStream = socket.getInputStream();
    		byte[] bytes = new byte[1024];
    		int len;
    		StringBuilder sb = new StringBuilder();
    		while ((len = inputStream.read(bytes)) != -1) {
    			// 注意指定编码格式，发送方和接收方一定要统一，建议使用UTF-8
    			sb.append(new String(bytes, 0, len, "UTF-8"));
    		}
    		System.out.println("get message from server: " + sb);
    
    
    		inputStream.close();
    		outputStream.close();
    		socket.close();
    	}
    
    
    }

三、先启动服务器端，再启动客户器端