java - 一个简单的客户端/服务器聊天程序

Question

我正在尝试使用 java 创建一个简单的聊天程序，其中包含表单、客户端表单和服务器表单，客户端表单包含一个 TextField 和一个 Button(发送按钮)，服务器表单包含一个 TextArea .

当我点击发送按钮时，它应该将 TextField 中的书写文本发送到服务器表单中的 TextArea。

第一次它可以工作，但是当我第二次点击按钮时它就不起作用了。

这是我在服务器表单中使用的代码:

public class Server extends javax.swing.JFrame implements Runnable {

    private Thread th;

    public Server() {
        initComponents();
        th = new Thread(this);
        th.start();
    }

    // The main method was here

    @Override
    public void run() {

        // Etablir la connexion
        try {
            ServerSocket ecoute;
            ecoute = new ServerSocket(1111);
            Socket service = null;
            System.out.println("Serveur en attente d'un client !");
            while (true) {

                service = ecoute.accept();
                System.out.println("Client connécté !");
                DataInputStream is = new DataInputStream(service.getInputStream());
                jTextArea1.setText("Client dit : "+ is.readUTF().toUpperCase());
                service.close();
            }
        } catch (IOException e) {
            e.printStackTrace();

        }
    }
}

这是客户端表单的代码:

    public class Client extends javax.swing.JFrame {

    DataOutputStream os;

    private void jButton2ActionPerformed(java.awt.event.ActionEvent evt) {
        try {
            os.writeUTF(jTextField1.getText());
        } catch (IOException ex) {
            Logger.getLogger(Client.class.getName()).log(Level.SEVERE,null, ex);
        }
    }

    public static void main(String args[]) {
        java.awt.EventQueue.invokeLater(new Runnable() {

            public void run() {
                Client c = new Client();
                c.setVisible(true);

                try {
                    Socket s = new Socket("localhost", 1111);
                    c.os = new DataOutputStream(s.getOutputStream());
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        });
    }

}

Answer 1

您的问题出在服务器代码中:在服务器端接收来自不同客户端的各种消息，对于每个接受，即每个客户端，您必须创建一个线程来处理其请求，因为您使用的是 TCP 连接。 (- 您每次接受只处理一个请求，然后关闭连接)。

我清理了您代码中与套接字无关的部分(即客户端中与 GUI 相关的一些不完整部分)，因此我提供了一个适用于许多同时客户端连接的不同版本，您可以看到所有消息到达服务器，而不仅仅是第一条消息。

服务器代码:

import java.io.*;
import java.net.*;


public class Server {

    public static void run() {
        try
        {
            ServerSocket ecoute;
            ecoute = new ServerSocket(1111);
            Socket service = null;
            System.out.println("serveur en attente d'un client!");
            while(true)
            {
                service = ecoute.accept();
                System.out.println("client connécté!");
//              ##call a new thread
                WorkerThread wt = new WorkerThread(service);
                wt.start();
            }
        }
        catch(IOException e)
        {
            e.printStackTrace();
        }
    }

    public static void main(String args[]) {
        run();
    }
}


class WorkerThread extends Thread {
    Socket service;
    WorkerThread(Socket service) {
        this.service = service;
    }

    public void run() {
    boolean flag=true;    //you can change this flag's condition, to test if the client disconects
    try
    {
        while (flag){
            DataInputStream is = new DataInputStream(service.getInputStream());
            System.out.println("client dit: " + is.readUTF().toUpperCase());
        }
        service.close();
    }
    catch(IOException e)
        {
            e.printStackTrace();
        }
    }
}

客户代码:

import java.io.*;
import java.io.*;
import java.net.*;
import java.util.logging.*;


public class Client {

DataOutputStream os;

public static void main(String args[]) {
java.awt.EventQueue.invokeLater(new Runnable() {

        public void run() {
               Client c = new Client();
        try {
            Socket s = new Socket("localhost", 1111);
            c.os = new DataOutputStream(s.getOutputStream());
            while (true){
                String str = Input.read_string();
                c.os.writeUTF(str);
            }
        } catch ( IOException e) {
            // TODO auto-generated catch block
            e.printStackTrace();
        }
            }
        });
    }
}

public class Input{
    public static String read_string(){
        String read="";
        try{
            read = new BufferedReader(new InputStreamReader(System.in), 1).readLine();
        }catch (IOException ex){
            System.out.println("error reading from the input stream!");
        }
        return read;
    }
}

之后，您可能知道，您需要将所有到达服务器的消息发送给聊天室中的所有客户端。