使用套接字连接的简单聊天 [英] Simple Chat using socket connection

问题描述

我正在尝试进行简单的聊天.我有一台可以处理更多客户端的服务器.这是我到目前为止所做的:连接，我可以在服务器上确定哪个客户端正在发送消息，但是问题是在客户端上我无法像在服务器上那样进行完整的对话.例如

I am trying to make a simple chat. I have a server that handles more clients. This is what i did until now : the connections , i can identify on my server which client is sending the message , but the problem is that on client i can't get full conversation like on the server .For example

Client_1  (writing)
msg : hi

Client_2 (writing)
msg : hi from cl2

results 

Server :
Client_1 : hi
Client_2 : hi from cl2

Client_1 
Client_1 : hi

Client_2 
Client_2 :hi from cl2

我想实现两个客户端具有与服务器相同的信息.

I want to achieve that both clients have the same info as server has.

My Server Script :
public class Server {

    public static void main(String[] args) throws IOException {
        ServerSocket server = new ServerSocket(1900);
        System.out.println("waiting");
        while (true) {
            Socket sock = server.accept();
            System.out.println("Client nou conectat !");
            ClientHandler cH = new ClientHandler(sock);
            cH.start();
        }
    }
}

class ClientHandler extends Thread {
    BufferedReader in;
    PrintWriter out;

    ClientHandler(Socket sock) throws IOException {
        out = new PrintWriter(new OutputStreamWriter(sock.getOutputStream()),
                true);
        in = new BufferedReader(new InputStreamReader(sock.getInputStream()));
    }

    public void run () {
            try {
                out.println("Hello from server"); //hello message to client
        while (true) {
            String linie = in.readLine();
            if (linie==null)
                return;
            System.out.println(linie); //message from client 
            out.println(linie);
        }
    }catch(Exception e) {e.printStackTrace();}
        }
}

客户端脚本

public class Client {
    public static void main(String[] args) throws Exception {
    //  String ip ="192.168.1.12";
        String ip ="localhost";
        Socket sock = new Socket(ip, 1900); // localhost daca ii pe
                                                        // acelasi pc serverul
                                                        // si clientul,altfel
                                                        // IPul
        PrintWriter out = new PrintWriter(new OutputStreamWriter(
                sock.getOutputStream()), true);
        BufferedReader in = new BufferedReader(new InputStreamReader(
                sock.getInputStream()));
        String linie = in.readLine();
        System.out.println("Server :" + linie);//meesage from server
        BufferedReader console = new BufferedReader(new InputStreamReader(
                System.in));

        while (true) {
            linie = console.readLine();
            out.println("Client_1 :"+linie); // sending to server
            String linie2 =in.readLine();
            System.out.println(linie2); //resend message to client
        }
    }
}

我希望我能很好地解释我的问题:D.感谢所有的建议

I hope i explained well my problem :D . Thanks in advice for all

推荐答案

在服务器端.

您为与服务器的每个客户端连接创建一个ClientHandler，这很好，然后读取来自每个ClientHandler的内容.

You create a ClientHandler for each client connection to the server, this is Ok, then reading what comes from each ClientHandler.

但是每个ClientHandler都不知道服务器上还有多少其他客户端，您必须连接它们".

But each ClientHandler is agnostic to how many other clients are on the server, you have to "connect them".

我会创建一个

public class ClientDispatcher{

    private List<ClientHandler> clients;

}

并针对ClientHandler收到的每条消息通知ClientDispatcher，以便他可以将消息分发"给其他人.

and notify that ClientDispatcher for every message a ClientHandler has so he can "dispatch" the message to the others.

这篇关于使用套接字连接的简单聊天的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！