java学习笔记之TCP实现的简单聊天

简单聊天Demo

使用tcp协议实现的简单聊天功能（非常简单的）

　　思想：使用2个线程，一个线程是用来接收消息的，另一个线程是用来发消息的。

　　客户端Demo代码：

public class SendDemo {
    public static void main(String[] args) throws Exception{
        Socket socket= new Socket(InetAddress.getLocalHost(),8888);
        SendImpl  sendImpl= new SendImpl(socket);
        //发送的线程
        new Thread(sendImpl).start();
        //接收的线程
        ReciveImpl reciveImpl=new ReciveImpl(socket);
        new Thread(reciveImpl).start();
    }

}

　　服务器端Demo代码：

public class ServerDemo {
    public static void main(String[] args) throws Exception {
        ServerSocket serverSocket =new ServerSocket(8888);
        Socket socket=serverSocket.accept();
        SendImpl sendImpl= new SendImpl(socket);
        new Thread(sendImpl).start();
        ReciveImpl reciveImpl=new ReciveImpl(socket);
        new Thread(reciveImpl).start();
    }

}

　　发送线程的Demo代码：

public class SendImpl implements Runnable{
    private Socket socket;
    public SendImpl(Socket socket) {
        this.socket=socket;
        // TODO Auto-generated constructor stub
    }
    @Override
    public void run() {
        Scanner scanner=new Scanner(System.in);
        while(true){
            try {
                OutputStream outputStream = socket.getOutputStream();
                String  string= scanner.nextLine();
                outputStream.write(string.getBytes());
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

}

　　接收线程的Demo代码：

public class ReciveImpl implements Runnable {
    private Socket socket;
    public ReciveImpl(Socket socket) {
        this.socket=socket;
        // TODO Auto-generated constructor stub
    }
    @Override
    public void run() {
        while(true ){
            try {
                InputStream inputStream = socket.getInputStream();
                byte[] b=new byte[1024];
                int len= inputStream.read(b);
                System.out.println("收到消息："+new String(b,0,len));
                
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

}