JAVA中TCP/IP通信

分手后的思念是犯贱 2022-05-29 00:45 175阅读 0赞

Client端
    Socket socket = new Socket("127.0.0.1",8088);
    		System.out.println("已连接到服务器！！！");
    		
    		new Thread(new ClientReader(socket)).start();
    		new Thread(new ClientWriter(socket)).start();
    =========================================================================
    public class ClientReader implements Runnable {
    private Socket socket;
    	
    	public ClientReader(){}
    	public ClientReader(Socket socket){
    		this.socket = socket;
    	}
    
    	public void run(){
    		while(true){
    			try {
    				BufferedReader reader = new BufferedReader(
    						new InputStreamReader(socket.getInputStream()));
    			String clientReader = reader.readLine();
    				//显示输出消息来自于谁；
    				System.out.println("消息来自："+
    			socket.getInetAddress().getHostName()+clientReader);
    				if("bye".equals(clientReader)){
    					System.out.println("对方已下线");
    					System.exit(0);
    				}
    ==================================================================================
    server端：
    public static void main(String[] args) throws IOException {
    		System.out.println("已打开端口");
    		ServerSocket server = new ServerSocket(8088);
    		System.out.println("客户端连接上");
    		Socket socket = server.accept();
    		
    		new Thread(new ServerReader(socket)).start();
    		new Thread(new ServerWriter(socket)).start();;
    ================================================================================
    public class ServerReader implements Runnable{
    	private Socket server;
    	
    	public ServerReader(){}
    	
    	public ServerReader(Socket server){
    		this.server = server;
    		
    	}
    	@Override
    	public void run() {
    		while(true){
    			
    		BufferedReader reader;
    		try {
    			reader = new BufferedReader(new InputStreamReader(server.getInputStream()));
    			String ServerReader = reader.readLine();
    			System.out.println("消息来自："+
    			server.getInetAddress().getHostName()+ServerReader);
    			if("bye".equals(ServerReader)){
    				System.out.println("对方已下线");
    				System.exit(0);
    			}