服务器不解码数据包答案

【问题标题】：Server not decoding packets服务器不解码数据包
【发布时间】：2016-02-20 19:32:46
【问题描述】：

我正在为我的项目设计一个通信系统。但是，我在处理数据包时遇到了一些麻烦。我的通信系统是用 java.net 编写的，使用 ServerSocket、Socket、BufferedReader 和 PrintWriter。

目前，我的系统每 500 毫秒侦听一次数据包。它可以很好地处理登录数据包，但无法处理登录后数据包（发送 id、断开连接）。每 500 毫秒，我需要我的服务器监听登录和登录后数据包（发送 id，断开连接）。我将如何设计一种检测和处理登录后数据包的方法？登录数据包由握手码、用户名和密码组成。登录后数据包（打印ID、断开连接）由握手码、用户ID、事件ID和其他事件参数组成。

使用 bufferedreader 和 printwriter 以文本行的形式发送和接收数据包。

这是我的服务器端解码器

    protected void decode(Socket server) throws Exception {
    final BufferedReader reader = new BufferedReader(new InputStreamReader(server.getInputStream()));
    final int handshake = Integer.parseInt(reader.readLine());
    if (handshake == LOGIN) {
        final Session session = new LoginSession(server, reader);
        session.read(-1);
    } else if (handshake == POST_LOGIN) {
        final int index = Integer.parseInt(reader.readLine());
        final int opcode = Integer.parseInt(reader.readLine());
        final Session session = store.get(index).getSession();
        session.reader = reader;
        session.read(opcode);
    }

}

@Override
public void run() {
    Socket server;
    try {
        server = serverSocket.accept();
        server.setTcpNoDelay(false);
        decode(server);
    } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

}

这些是我的客户端 -> 服务器数据包

    public void sendLogin() {
    write.write("100");
    write.write('\n');
    write.write("raees2");
    write.write('\n');
    write.write("LOL2");
    write.write('\n');
    write.flush();
}

public void sendPrintId() throws NumberFormatException, IOException {
    final BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
    final int id = Integer.parseInt(reader.readLine());
    System.out.println(id);

    write.write("101");
    write.write('\n');
    write.write(Integer.toString(id));
    write.write('\n');
    write.write(Integer.toString(0));
    write.write('\n');
    write.write(Integer.toString(10003));
    write.write('\n');
    write.flush();
}

public void sendDisconnection() throws NumberFormatException, IOException {
    final BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
    final int id = Integer.parseInt(reader.readLine());
    System.out.println(id);

    write.write("101");
    write.write('\n');
    write.write(Integer.toString(id));
    write.write('\n');
    write.write(Integer.toString(1));
    write.write('\n');
    write.flush();
}

【问题讨论】：

请不要破坏您的帖子，这些帖子是根据 CC by-SA 授权给 Stack Overflow 的。

标签： java sockets networking tcp bufferedreader

【解决方案1】：

基本上，您只需要一个循环来继续从流中读取，直到对话完成。现在，它读取一条消息并终止。

我不确定您的协议是如何工作的，但这样的事情可以作为一个起点：

protected void decode(Socket server) throws Exception {
    final BufferedReader reader = new BufferedReader(new InputStreamReader(server.getInputStream()));

    /*
     * Somewhere in this loop, detect your protocol's termination condition
     * and break out.
     */

    for (;;) {
        final int handshake = Integer.parseInt(reader.readLine());
        if (handshake == LOGIN) {
            final Session session = new LoginSession(server, reader);
            session.read(-1);
        } else if (handshake == POST_LOGIN) {
            final int index = Integer.parseInt(reader.readLine());
            final int opcode = Integer.parseInt(reader.readLine());
            final Session session = store.get(index).getSession();
            session.reader = reader;
            session.read(opcode);
        }
    }
}

如果您需要同时处理多个连接，您可能希望您的接受线程为每个成功连接的连接启动一个新的客户端线程，因为decode 将在等待下一条消息时阻塞。

【讨论】：