java实现简易聊天功能

package test;

import java.net.ServerSocket;
import java.net.Socket;

public class  ChatServerThread{
    //服务端
    public static void main(String[] args) throws Exception{
        ServerSocket serverSocket = new ServerSocket(8888);
        //监听8888号端口
        Socket socket = serverSocket.accept();
        //开启发送和接收线程
        Sendlmpl sendlmpl=new Sendlmpl(socket);
        new Thread(sendlmpl).start();
        Receivelmpl receivelmpl=new Receivelmpl(socket);
        new Thread(receivelmpl).start();
    }
}

package test;

import test.Receivelmpl;
import test.Sendlmpl;

import java.net.Socket;

public class ChatClientThradd {
    //客户端
    public static void main(String[] args) throws Exception{
        //连接8888号端口
        Socket socket=new Socket("127.0.0.1",8888);
        //开启发送和接收线程
        Sendlmpl sendlmpl=new Sendlmpl(socket);
        new Thread(sendlmpl).start();
        Receivelmpl receivelmpl=new Receivelmpl(socket);
        new Thread(receivelmpl).start();
    }
}

package test;

import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

public class Sendlmpl implements Runnable {
    //发送类
    private Socket socket;

    public Sendlmpl(Socket socket) {
        this.socket = socket;
    }

    @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) {
                e.printStackTrace();
            }
        }
    }
}

package test;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class Receivelmpl implements Runnable{
    //接收类
    private Socket socket;

    public Receivelmpl(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        //循环接收网络发来的信息
        while (true) {
            try {
                InputStream inputStream=socket.getInputStream();
                byte [] bytes=new byte[1024];
                int z=inputStream.read(bytes);
                System.out.println(new String(bytes,0,z));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}