Java 网络编程----回顾传统网络编程BIO

旧城等待， 2022-06-01 09:26 279阅读 0赞

**一.介绍**

**1.1 网络编程****的基本模型是Client/Server模型,也就是两个进程直接进行相互通信,其中服务端提供配置信息(绑定的IP地址和监听端口),客户端通过连接操作向服务端监听的地址发起连接请求,通过三次握手建立连接,如果连接成功,则双方即可以进行通信(网络套接字Socket).模型如下图所示**

**![Center][]**

**1.2 伪异步IO**

**采用线程池和任务队列可以实现一种伪异步的IO通信框架.就是客户端的Socket封装成一个task任务(实现Runable接口的类),然后投递到线程池中去,配置相应的队列进行实现.模型如下图:**

**![Center 1][]**

**二.代码示例**

package com.east.socket;
    
    import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Server {
    
    	final static int PORT = 8765;
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
            ServerSocket server = null;
            try {
    			server = new ServerSocket(PORT);
    			System.out.println("server start...");
    			//进行阻塞
    			Socket socket = server.accept();
    			//新建一个新线程执行客户端的任务
                new Thread(new ServerHandler(socket)).start();
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}finally {
    			
    		}
    	}
    
    }

package com.east.socket;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.Socket;
    
    public class ServerHandler implements Runnable {
    
    	private Socket socket;
    	
    	public ServerHandler(Socket socket) {
    		super();
    		this.socket = socket;
    	}
    
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
            BufferedReader in = null;
            PrintWriter out = null;
            try {
    			in = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
    			out = new PrintWriter(this.socket.getOutputStream(),true);
    			String body = null;
    			while(true){
    				body = in.readLine();
    				if(body == null) break;
    				System.out.println("Server :" + body);
    				out.println("服务器端回送响应的数据.");
    			}
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}finally {
    			if(in !=null){
    				try {
    					in.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if(out != null){
    				try {
    					out.close();
    				} catch (Exception e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    		}
    	}
    
    }

package com.east.socket;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.Socket;
    
    public class Client {
    
    	final static String ADDRESS = "127.0.0.1";
    	final static int PORT = 8765;
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
            Socket socket = null;       
            BufferedReader in = null;
            PrintWriter out = null;
            
            try {
    			socket = new Socket(ADDRESS, PORT);                  //创建Socket
    			in = new BufferedReader(new InputStreamReader(socket.getInputStream()));     //流读写
    			out = new PrintWriter(socket.getOutputStream(),true);
    			
    			//向服务器端发送数据(创建好连接后的操作)
    			out.println("接受到客户端的请求数据...");
    			String response = in.readLine();
    			System.out.println("Client: " + response);
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} finally {
    			if(in != null){
    				try {
    					in.close();
    				} catch (IOException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if(out != null){
    				out.close();
    			}
    		}
            
    	}
    
    }

[Center]: /images/20220601/cadb82127d8d4047922e135080b795de.png
[Center 1]: /images/20220601/51e56cc8e50741f9956d14a882c2cb4e.png