java实现实时通信聊天程序

利用TCP传输数据，编写客户端和服务器的程序，实现两个程序间的实时通信。

在每个程序中实现了实时的发送与接收数据的功能。

客户端的io界面

服务器端的io界面

io演示

程序以两端分别输入close字符串作为结束标识。在一端输入close时，终止发送、一端接收到close时，终止接收。所演示的客户端来自个人电脑IDEA调试运行。服务器端来自阿里云服务器centos系统下的jdk环境。该程序需要用到java的 I/O 流、多线程、网络编程的相关知识。

一、客户端

由于发送和接收数据是并行的，为了使得时刻都能同时进行接受与发送的功能，使用多线程，将接收和发送分别封装为两个Runnable实现类。获取io信息。

ClientDemo类的源码：

public class ClientDemo {
    public static Socket s;
    public static void main(String[] args) throws IOException, InterruptedException {
        s = new Socket("localhost", 10000);        //此处的参数一填写服务器端ip地址
        System.out.println("连接成功");
        Thread send = new Thread(new COUT());
        Thread receive = new Thread(new CIN());
        send.start();
        receive.start();
        send.join();        //发送和接收执行完毕时，关闭套接字
        receive.join();        //因此待这两个线程结束时才回到主线程执行。
        s.close();
    }
}

创建全局变量套接字s，在主进程中给s进行初始化，然后启动发送和接收功能的两个线程。

Socket构造时传递的两个参数，其一填写服务器地址。或者填写localhost即127.0.0.1回送地址，本机即可运行服务器端和客户端进行本地数据传输。

其二是端口数，需要保持客户端和服务器端的套接字绑定的端口数一致。尽可能选用数量大的端口以免被占用，如果运行时报错端口已占用可以尝试更改端口数，范围在65536内。

客户端发送和接收类的源码：

class CIN implements Runnable{
    @Override
    public void run() {        //接收模块
        try {
            InputStream is = ClientDemo.s.getInputStream();//通过全局套接字s获取连接后的流
            in(is);
        }
        catch (IOException o) {
            o.printStackTrace();
        }
    }
    public static void in(InputStream is) throws IOException{
        while(true){
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            String line = new String(bytes,0,len);
 
            System.out.println("对方:   "+line);
            if(line.equals("close"))
                break;
        }
    }
}
 
class COUT implements Runnable{
    @Override
    public void run() {        //发送模块
        try {
            OutputStream os = ClientDemo.s.getOutputStream();//套接字获取流
            out(os);
        }
        catch (IOException o){
            o.printStackTrace();
        }
    }
    public static void out(OutputStream os) throws IOException{
        Scanner sc = new Scanner(System.in);
        while(true) {
            String line = sc.nextLine();
            os.write(line.getBytes());
            if(line.equals("close"))
                break;
        }
        sc.close();
    }
}

由于IO流都由socket创建，因此程序结束时需要关闭s即可。

二、服务器

ServerDemo类的源码:

public class ServerDemo {
    public static ServerSocket ss;
    public static Socket s;
 
    public static void main(String[] args) throws IOException, InterruptedException {
        ss = new ServerSocket(10000);        //监听端口10000，对应客户端套接字绑定的端口
        s = ss.accept();        //提取监听套接字中的一个连接
        System.out.println("连接成功");
        Thread send = new Thread(new SOUT());
        Thread receive = new Thread(new SIN());
        send.start();
        receive.start();
        send.join();
        receive.join();
        ss.close();
    }
}

创建服务器套接字对象并监听，并接收连接请求。

此处的代码与客户端大同小异，完成连接后的代码基本一致。

服务器端发送和接收类的源码：

class SIN implements Runnable{
    @Override
    public void run() {
        try {
            InputStream is = ServerDemo.s.getInputStream();
            in(is);
        }
        catch (IOException o) {
            o.printStackTrace();
        }
    }
    public static void in(InputStream is) throws IOException{
        while(true){
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            String line = new String(bytes,0,len);
            System.out.println("对方:   "+line);
            if(line.equals("close"))
                break;
        }
    }
}
class SOUT implements Runnable{
    @Override
    public void run() {
        try {
            OutputStream os = ServerDemo.s.getOutputStream();
            out(os);
        }
        catch (IOException o){
            o.printStackTrace();
        }
    }
    public static void out(OutputStream os) throws IOException{
        Scanner sc = new Scanner(System.in);
        while(true) {
            String line = sc.nextLine();
            os.write(line.getBytes());
            if(line.equals("close"))
                break;
        }
        sc.close();
    }
}

两者代码不同的地方在于由于套接字不同，返回的流实例不同。基本逻辑相同。

本地可同时运行客户端和服务器端，客户端套接字绑定本地ip地址，“localhost或127.0.0.1。

先开启服务器端进行监听，然后打开客户端向服务器端发起连接请求。连接成功后即可实时进行聊天。在程序中以一行为信息单元，键入若干字符后换行发送。另一端即可收到信息。

在一端键入“close”发送即可关闭当前程序的发送线程和接收程序的接收线程。待两个程序的所有发送和接收都结束时，关闭程序。

实测记录：将服务器端程序发送至云服务器通过jdk运行，并开启程序监听，将客户端的套接字指向服务器端的地址和监听端口。之后建立连接，可自由在两端传输信息。

来源：https://blog.csdn.net/weixin_53070478/article/details/123033189