使用套接字客户端-服务器-客户端通信实现聊天

Question

我已经实现了一个通过套接字进行通信的全局聊天。客户端写入一条消息，发送到服务器，然后服务器将消息发回给所有客户端。每个客户端都由一个名为ClientThread的类表示，因此每个客户端都是一个线程。每次新客户端连接时，我都会创建一个新的ClientThread实例，并将所有这些实例存储在列表中。现在我想实现一个私人聊天，这样每个客户端就可以私下与另一个客户端交谈（或者2,3或更多的群聊）。

我还想说一个事实，我只通过ChatMessage类的实例进行通信，这个类是我自己定义的，它有一个类型字段和一个消息字段。因此，每当一个用户向另一个用户发送私人消息时，服务器都会接收到类型为PRIVATEMESSAGE的消息，通过存储的对话遍历所有列表，并将消息发送给发送该请求的特定对话。

//output and input stream
    output = new ObjectOutputStream(socket.getOutputStream());
    input = new ObjectInputStream(socket.getInputStream());

// send messages
    public void sendMessage(Object msg) {
            try {
                
                output.writeObject(msg);
            } catch (IOException e) {
                e.printStackTrace();
            }
    }


public class ChatMessage implements Serializable {

    protected static final long serialVersionUID = 1112122200L;

    // The different types of message sent by the Client
    // WHOISIN to receive the list of the users connected
    // MESSAGE an ordinary message
    // LOGOUT to disconnect from the Server
    public static final int WHOISIN = 0;

    public static final int MESSAGE = 1;

    public static final int LOGOUT = 2;

    public static final int LOGIN = 3;
    
    public static final int PRIVATECONVERSATION = 4;
    
    public static final int PRIVATEMESSAGE = 5;
    
    private int type;
    private String message;

    // constructor
    public ChatMessage(int type, String message) {
        this.type = type;
        this.message = message;
    }

    // getters
    public int getType() {
        return type;
    }

    public String getMessage() {
        return message;
    }
}
 

现在是我的第二个问题：

Answer 1

对于您的第一个问题，看看这个，您可以创建一个类似的表，如此处指定的数据库设计，用于存储人与人之间的聊天消息

要发送文件，您可以将它们转换为字节并按如下方式发送：-

public byte[] read() throws IOException
{
    int length = inputStream.readInt();
    byte[] dataBytes = new byte[length];
    inputStream.readFully(dataBytes, 0, dataBytes.length);
    return dataBytes;
}

public void write(byte[] data, Short packetType) throws IOException
{
    outputStream.writeShort(packetType);
    outputStream.writeInt(data.length);
    outputStream.write(data);
    outputStream.flush();
}

要将文件转换为字节：-

Path path= Paths.get("file/path");
byte[] data = Files.readAllBytes(path);

要将字节转换回文件 ：-

byte[] data = read();
Path path = Paths.get("C:\myfile.FileType");
Files.write(path, bytes);

发送文件名及其扩展名，然后发送文件，这样您可以在另一端重新创建它。

Answer 2

我还编写了一个简单的聊天程序，并创建了一个“用户”类，将消息列表作为一个字段。每条消息都是一个带有“发件人”、“收件人”等和文本的对象。可以为每个用户单独迭代消息列表