TCP客户端服务器Demo

妖狐艹你老母 2021-12-05 18:09 417阅读 0赞

Client:

import java.io.IOException;  
    import java.io.InputStream;  
    import java.io.OutputStream;  
    import java.net.Socket;  
    import java.net.UnknownHostException;  
    import java.util.Scanner;  
      
    public class Client extends Thread {   
          
        //定义一个Socket对象 
        Socket socket = null;  
      
        public Client(String host, int port) {   
            try {   
                //需要服务器的IP地址和端口号，才能获得正确的Socket对象 
                socket = new Socket(host, port);  
            } catch (UnknownHostException e) {   
                e.printStackTrace();  
            } catch (IOException e) {   
                e.printStackTrace();  
            }  
              
        }  
      
        @Override  
        public void run() {   
            //客户端一连接就可以写数据个服务器了 
            new sendMessThread().start();  
            super.run();  
            try {   
                // 读Sock里面的数据 
                InputStream s = socket.getInputStream();  
                byte[] buf = new byte[1024];  
                int len = 0;  
                while ((len = s.read(buf)) != -1) {   
                    System.out.println(new String(buf, 0, len));  
                }  
              
            } catch (IOException e) {   
                e.printStackTrace();  
            }  
        }  
          
        //往Socket里面写数据，需要新开一个线程 
        class sendMessThread extends Thread{   
            @Override  
            public void run() {   
                super.run();  
                //写操作 
                Scanner scanner=null;  
                OutputStream os= null;  
                try {   
                    scanner=new Scanner(System.in);  
                    os= socket.getOutputStream();  
                    String in="";  
                    do {   
                        in=scanner.next();  
                        os.write(("客户端:"+in).getBytes());  
                        os.flush();  
                    } while (!in.equals("bye"));  
                } catch (IOException e) {   
                    e.printStackTrace();  
                }   
                scanner.close();  
                try {   
                    os.close();  
                } catch (IOException e) {   
                    e.printStackTrace();  
                }  
            }  
        }
      
            public static void main(String[] args) {   
                //需要服务器的正确的IP地址和端口号 
                 Client client=new Client("127.0.0.1", 6666);  
                 client.start();  
            }  
        }

Sever:

import java.io.IOException;  
    import java.io.InputStream;  
    import java.io.OutputStream;  
    import java.net.ServerSocket;  
    import java.net.Socket;  
    import java.util.ArrayList;  
    import java.util.List;  
      
    /** * 可以实现和客户端的相互发送消息的交互 可以是多台电脑 * * */  
      
    public class Server2 extends Thread {   
        // 用来存放连接上的用户的socket对象的值 
        List<Socket> list = new ArrayList<>();  
      
        // 定义服务器接口ServerSocket 
        ServerSocket server = null;  
      
        // 定义一个服务器，定义端口 
        public Server2(int port) {   
            try {   
                server = new ServerSocket(port);  
            } catch (IOException e) {   
                e.printStackTrace();  
            }  
        }  
      
        // 发送消息的线程 
        @Override  
        public void run() {   
            super.run();  
            try {   
      
                while (true) {   
                    // 建立socket接口，accept方法是一个阻塞进程,等到有用户连接才往下走 
                    // 定义Socket类 
                    Socket socket = server.accept();  
                    // 在服务器显示连接的上的电脑、 
                    String message = socket.getInetAddress().getHostAddress().toString();  
                    System.out.println(message+"连接上了");  
                    // 向用户发送消息 
                    SendMessageToAllUser(message);  
                    // 把连接上的用户添加到集合；里面去 
                    list.add(socket);  
                    //开始新连接用户的线程，用于该可以一直读取数据 
                    new readerThread(socket).start();;  
                }  
      
            } catch (IOException e) {   
                e.printStackTrace();  
            }  
        }  
      
        // 把消息发送给每一个用户，涉及到写的操作OutStream 
        private void SendMessageToAllUser(String message) {   
            // 拿到每一个用户的socket对象，对其进行写入数据 
            for (Socket socket : list) {   
                // 判读之前保存的连接是否还在 
                if (socket != null && socket.isConnected()) {   
                    try {   
                        OutputStream os = socket.getOutputStream();  
                        os.write(message.getBytes());  
                        os.flush();// 刷新一下写入的数据，很有必要 
                    } catch (IOException e) {   
                        e.printStackTrace();  
                    }  
                }  
            }  
        }  
      
        // 读取客户端的信息 
        class readerThread extends Thread {   
            InputStream is = null;  
      
            // 这里传入一个socket对象，因为每一个用户都要用一个不同的线程存放的socket对象来进行一直读取数据 
            public readerThread(Socket socket) {   
                try {  
                	 System.out.println("服务器在启动中...等待用户的连接"); 
                    // 获取输入流 
                    is = socket.getInputStream();  
                } catch (IOException e) {   
                    e.printStackTrace();  
                }  
            }  
      
            @Override  
            public void run() {   
                super.run();  
                try {   
                    int len = 0;  
                    byte[] buf = new byte[1024];  
                    while ((len = is.read(buf)) != -1) {   
                        // 把读取到的数据发送给其他用户 
                        SendMessageToAllUser(new String(buf, 0, len));
                        System.out.println("服务器接收到客户端的数据："+new String(buf,0,len)); 
                    }  
                } catch (IOException e) {   
                    e.printStackTrace();  
                }  
            }  
        }  
        public static void main(String[] args) {   
        	//这里服务器只需要定义一个端口号就可以了，IP地址程序会自动获取 
        	//但是客户端需要连接这个服务器时，需要知道它的IP地址还有端口号 
        	//ip地址的查看方法：进入cmd窗口，输入ipconfig/all可以看到 
        	 Server2 server=new Server2(6666);  
        	 server.start();  
        	}  
    }