学习Java Socket网络编程（二）

古城微笑少年丶 2021-12-04 05:41 327阅读 0赞

## Socket通信模型 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxODY2NTE2_size_16_color_FFFFFF_t_70][]

**大致流程：**

1.  建立连接：服务器端建立ServerSocket绑定指定端口等待连接
    
    客户端建立Socket向服务端发送请求
    
    服务端接受后创建连接Socket
2.  开始通信：通过输入流和输出流进行数据交换
3.  关闭Socket及相关资源

### 服务端ServerSocket类 ###

/*
     * 服务器端
     */
    public class Server {
    	public static void main(String[] args) {
    		try {
    			//1.创建服务器端socket。即ServerSocket，指定绑定的端口，并监听此端口
    			ServerSocket serverSocket = new ServerSocket(8888);
    			//2.调用accept()方法开始监听，等待客户端的连接
    			System.out.println("***服务器即将启动，等待客户端的连接***");
    			Socket socket = serverSocket.accept();
    			//3.获取输入流，并读取客户端信息
    			InputStream is = socket.getInputStream();//字节输入流
    			InputStreamReader isr = new InputStreamReader(is);//将字节流转换为字符流提高性能
    			BufferedReader br = new BufferedReader(isr);
    			String info = null;
    			while((info=br.readLine())!=null) {
    				System.out.println("我是服务器，客户端说："+info);
    			}
    			socket.shutdownInput();
    			//获取输出流，响应客户端请求
    			OutputStream os = socket.getOutputStream();
    			PrintWriter pw = new PrintWriter(os);
    			pw.write("欢迎您！");
    			pw.flush();//刷新缓存
    			socket.shutdownOutput();
    			//5.关闭相关资源
    			pw.close();
    			os.close();
    			br.close();
    			isr.close();
    			is.close();
    			socket.close();
    			serverSocket.close();
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}
    }

### 客户端Socket类 ###

/*
     * 基于TCP协议的Socket通信，实现用户登录
     * 客户端
     */
    public class Client {
    	public static void main(String[] args) {
    		try {
    			//1.创建客户端Socket，指定服务器地址和端口
    			Socket socket  = new Socket("localhost",8888);
    			//2.获取输出流。想服务端发送信息
    			OutputStream os = socket.getOutputStream();//字节输出流
    			PrintWriter pw = new PrintWriter(os);//将输出流包装成打印流
    			pw.write("用户名：admin;密码：123");
    			pw.flush();
    			socket.shutdownOutput();
    			//3.获取输入流，读取服务端响应
    			InputStream is = socket.getInputStream();
    			BufferedReader br = new BufferedReader(new InputStreamReader(is));
    			String info = null;
    			while((info=br.readLine())!=null) {
    				System.out.println("我是客户端，服务端说："+info);
    			}
    			socket.shutdownInput();
    			//4.关闭资源
    			br.close();
    			is.close();
    			pw.close();
    			os.close();
    			socket.close();
    			} catch (UnknownHostException e) {
    			e.printStackTrace();
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}
    }

### 运行结果 ###

**服务端：**

![20190717235536321.png][]

**客户端：**

![20190717235554633.png][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxODY2NTE2_size_16_color_FFFFFF_t_70]: /images/20211204/f72e0cece0bf430181e1e06bcbe9fddf.png
[20190717235536321.png]: /images/20211204/83af37c0e0124b519da797a45f054a0f.png
[20190717235554633.png]: /images/20211204/20a3412d091f42cdaf7f45508b51e7e1.png