2

我正在尝试使用java创建一个简单的聊天程序，其中包含表单、客户端表单和服务器表单，客户端表单包含一个TextField和一个按钮（发送按钮），服务器表单包含一个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();
                }
            }
        });
    }

}
4

2 回答 2

1

在您while(true)的代码部分中Server- 您在阅读一次后关闭套接字，而在客户端您不会重新打开 a Socket（和新的InputStream）。我的建议是，您的while(true)部分中有另一个循环，它将继续读取并显示新数据，直到达到 EOF。

于 2013-03-03T18:08:57.690 回答
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;
    }
}

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

于 2013-03-03T19:05:38.753 回答