基于TCP协议实现客户服务器的全双工通信

男娘i 2022-08-27 13:47 194阅读 0赞

import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    
    public class MainServer 
    {
    	public static void main (String args[]) throws Exception 
    	{
    		ServerSocket ss=new ServerSocket(5000);
    		while(true)
    		{
    			Socket socket=ss.accept();//处于等待状态，等待客户端与其进行连接
    		//当客户端与服务器建立连接后，服务器应该继续进行监听，判断是否有其他客户端与服务器进行连接
    		//启动读写线程
    			new ServerInputThread(socket).start();
    			new ServerOutputThread(socket).start();
    		}
    	}
    }
    
    
    import java.io.BufferedInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.Socket;
    
    public class ServerInputThread extends Thread
    {
    	private Socket socket;
    	public ServerInputThread(Socket socket)
    	{
    		this.socket=socket;
    	}
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
    		try {
    			InputStream is=socket.getInputStream();
    			BufferedInputStream bis=new BufferedInputStream(is);
    			while(true)
    			{
    				byte [] by=new byte[1024];
    				bis.read(by);
    				String str=new String(by);
    				System.out.println(str);
    			}
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    }
    
    
    import java.io.BufferedOutputStream;
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.Socket;
    
    
    public class ServerOutputThread extends Thread
    {
    	private Socket socket;
    	public ServerOutputThread(Socket socket)
    	{
    		this.socket=socket;
    	}
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
    		try {
    			OutputStream os=socket.getOutputStream();
    			BufferedOutputStream bos=new BufferedOutputStream(os);
    			while(true)
    			{
    				BufferedReader reader=new BufferedReader(new InputStreamReader(System.in));
    				String str=reader.readLine();
    				bos.write(str.getBytes());
    			}
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    	
    }
    
    
    import java.io.IOException;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    
    public class MainClient 
    {
    	public static void main(String srga[]) throws UnknownHostException, IOException
    	{
    		Socket socket =new Socket("127.0.0.1",5000);
    		ClientInputThread cit=new ClientInputThread(socket);
    		ClientOutputThread cot=new ClientOutputThread(socket);
    		cit.start();
    		cot.start();
    		
    	}
    }
    
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.Socket;
    
    
    public class ClientInputThread extends Thread 
    {
    	private Socket socket;
    	public ClientInputThread(Socket socket)
    	{
    		this.socket=socket;
    	}
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
    		try {
    			InputStream is=socket.getInputStream();
    			while(true)
    			{
    				byte [] by=new byte[1024];
    				is.read(by);
    				String str=new String(by);
    				System.out.println(str);
    			}
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    }
    
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.Socket;
    
    
    public class ClientOutputThread  extends Thread
    {
    	private Socket socket;
    	public ClientOutputThread (Socket socket)
    	{
    		this.socket=socket;
    	}
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
    		try {
    			OutputStream os=socket.getOutputStream();
    			//通过键盘输入数据,使用Buffered缓冲流进行行读取
    			while(true)
    			{
    				BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
    				String str=br.readLine();
    				byte[] by=new byte[1024];
    				by=str.getBytes();
    				os.write(by);
    			}
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    }