java - 编写点对点聊天系统时遇到问题-6ren

java - 编写点对点聊天系统时遇到问题

转载作者：太空宇宙更新时间：2023-11-04 11:52:09

这是我收到的问题陈述:

设计一个协议(protocol)，其中服务器负责匹配两个聊天客户端。服务器在 TCP 端口上监听即将到来的连接。如果没有客户端连接到要配对的服务器，则服务器接受连接的客户端，并使其等待另一个客户端。为此，它会向连接客户端发送一条消息以等待。当收到此命令时，客户端构造另一个服务器套接字实例来监听端口。然后，客户端向服务器发送一条消息，其中包含新创建的服务器监听的端口号。当另一个客户端 C2 在 C1 等待期间寻求与服务器的连接时，服务器会通过向 C2 发送消息“PEER_LOC $h:$p”来通知 C2 C1 的存在，其中 $h 是 C1 的主机名(或 IP 地址)，$p 是 C1 正在等待的端口号。 C2 收到此消息后，会使用获得的信息寻求与 C1 的连接。客户端从用户处获取消息。然后，两个客户端交换消息，直到任何一方发送流结束”(Linux 中的 Ctrl-D)。然后它们的守恒被终止。复杂的方法可能会使用多个线程、超时等，但在这个问题中不是必需的。

我的问题是将两个客户端连接到我的服务器。我运行我的服务器程序，然后运行另外两个客户端类，它们彼此重复，只是名称不同。我可以连接到其中一个，但另一个似乎永远等待。

这些是我开设的类(class)。

服务器:

package chatserver2;

import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.*;
   // import all the class that you will need for functionailty

// extends jframe to develop gui's in java
public class Server {

    private static ObjectOutputStream output; // stream data out
    private static ObjectInputStream input; // stream data in
    private static ServerSocket server;
    private static Socket connection; // socket means set up connetion between 2 computers

    private static int n;

//Constructor
    public static void main(String[] args) throws IOException {

        Server obj = new Server();
        obj.RunServer();

        try {
            while (true) {

                Handler obj2 = new Handler();

                obj2.start();
                System.out.println("Accepted connection from "
                        + connection.getInetAddress() + " at port "
                        + connection.getPort());

                n++;
                System.out.println("Count " + n);
            }
        } finally {
            connection.close();
        }

    }

    public Server() {

    }

// run the server after gui created
    public void RunServer() {

        try {
            server = new ServerSocket(6789); // 1st number is port number where the application is located on the server, 2nd number is the amount of people aloud to connect
            while (true) {

                try {
                    waitForConnection(); // wait for a connection between 2 computers 
                    setupStreams();  // set up a stream connection between 2 computers to communicate
                    whileChatting();  // send message to each other
                    // connect with someone and have a conversation
                } catch (EOFException eofException) {

                }
            }
        } catch (IOException ioException) {

            ioException.printStackTrace();
        }
    }

//Wait for a connection then display connection information
    private void waitForConnection() {

        try {
            connection = server.accept();
        } catch (IOException ioexception) {

            ioexception.printStackTrace();
        }

    }
    // stream function to send and recive data

    private void setupStreams() throws IOException {

        output = new ObjectOutputStream(connection.getOutputStream()); // set up pathway to send data out
        output.flush(); // move data away from your machine
        input = new ObjectInputStream(connection.getInputStream()); // set up pathway to allow data in

    }

// this code while run during chat conversions
    private void whileChatting() throws IOException {

        String message = "WAIT ";
        sendMessage(message);

        do {

            try {

                message = (String) input.readObject(); // stores input object message in a string variable

                System.out.println("Message from Client " + message);
            } catch (ClassNotFoundException classnotfoundException) {

            }
        } while (!message.equals("CLIENT - END"));// if user types end program stops

    }

    private void closeChat() {

        try {

            output.close();
            input.close();
            connection.close();

        } catch (IOException ioexception) {

            ioexception.printStackTrace();
        }
    }

// send message to the client
    private void sendMessage(String message) {

        try {

            output.writeObject(message);
            output.flush();

            System.out.println("Message to client " + message);

        } catch (IOException ioexception) {

        }

    }

    public static class Handler extends Thread {

        private Socket connection;

        public Handler() {

            String message = "WAIT";

        }

        public void run() {

            System.out.println("Connect" + Server.connection);
            while (true) {

                try {
                    waitForConnection();
                    setupStreams();
                    whileChatting();
                } catch (IOException ex) {
                    Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
                }

            }

        }

        private void waitForConnection() {

            System.out.println("server" + server);
            try {
                connection = server.accept();
            } catch (IOException ioexception) {

                ioexception.printStackTrace();
            }
            System.out.println("Connection" + connection);

        }

        private void setupStreams() throws IOException {

            output = new ObjectOutputStream(connection.getOutputStream()); // set up pathway to send data out
            output.flush(); // move data away from your machine
            input = new ObjectInputStream(connection.getInputStream()); // set up pathway to allow data in

        }

        private void whileChatting() throws IOException {

            String message = " You are now connected ";
            sendMessage(message);

            do {

                try {

                    message = (String) input.readObject();

                } catch (ClassNotFoundException classnotfoundException) {

                }
            } while (!message.equals("CLIENT - END"));

        }

        private void closeChat() {

            try {

                output.close();
                input.close();
                connection.close();

            } catch (IOException ioexception) {

                ioexception.printStackTrace();
            }
        }

        static private void sendMessage(String message) {

            try {

                output.writeObject(message);
                output.flush();

            } catch (IOException ioexception) {

            }

        }

    }
}

一个重复的客户端类 C1 或 C2:

package chatserver2;

import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
   // import all the class that you will need for functionailty

// extends jframe to develop gui's in java
public class Client1 extends JFrame {

    private JTextField userInput; // 
    private JTextArea theChatWindow; //
    private ObjectOutputStream output; // stream data out
    private ObjectInputStream input; // stream data in

    private Socket connection; // socket means set up connetion between 2 computers

//Constructor
    public Client1() {

    }

// run the server after gui created
    public void RunClient() {

        try {
            connection = new Socket("localhost", 6789);// 1st number is port number where the application is located on the server, 2nd number is the amount of people aloud to connect
            while (true) {

                try {
                    // wait for a connection between 2 computers 
                    setupStreams();  // set up a stream connection between 2 computers to communicate
                    whileChatting();  // send message to each other
                    // connect with someone and have a conversation
                } catch (EOFException eofException) {

                } finally {

                    closeChat();
                }
            }
        } catch (IOException ioException) {

            ioException.printStackTrace();
        }
    }

//Wait for a connection then display connection information
    // stream function to send and recive data
    private void setupStreams() throws IOException {

        output = new ObjectOutputStream(connection.getOutputStream()); // set up pathway to send data out
        output.flush(); // move data away from your machine
        input = new ObjectInputStream(connection.getInputStream()); // set up pathway to allow data in

    }

// this code while run during chat conversions
    private void whileChatting() throws IOException {

        String message = "";

        do {
            // have conversion while the client does not type end
            try {

                message = (String) input.readObject(); // stores input object message in a string variable
                System.out.println("message " + message);
                if (message.equals("WAIT")) {
                    ServerSocket server2 = new ServerSocket(5000);
                    System.out.println("Hello");
                    message = "5000";
                    sendMessage(message);

                }
                System.out.println("From server " + message);

            } catch (ClassNotFoundException classnotfoundException) {

            }
        } while (!message.equals("CLIENT - END"));// if user types end program stops

    }

    private void closeChat() {

        try {

            output.close(); // close output stream
            input.close(); // close input stream
            connection.close(); // close the main socket connection

        } catch (IOException ioexception) {

            ioexception.printStackTrace();
        }
    }

// send message to the client
    private void sendMessage(String message) {

        try {

            output.writeObject(" - " + message);
            output.flush(); // send all data out

        } catch (IOException ioexception) {

            theChatWindow.append("\n ERROR: Message cant send");
        }

    }

//
//
    public static void main(String[] args) {
        Client1 obj = new Client1();
        obj.RunClient();
    }

}

我可以连接到我运行的第一个客户端，第二个客户端则永远等待。如有任何建议或意见，我们将不胜感激。

最佳答案

您正在阻止服务器周期。您应该为来自客户端的每个连接启动新线程。我会将 waitForConnection() 与 RunServer 方法中服务器循环中的下游代码分开。所以你的 while 循环应该是这样的:

public static void RunClient() {
    ...
        while (true) {
            try {
                final Server srv = waitForConnection(); // wait for a connection between 2 computers 
                new Thread(new Runnable() {
                    public void run() {
                        try {
                            srv.setupStreams();  // set up a stream connection between 2 computers to communicate
                            srv.whileChatting();  // send message to each other
                            // connect with someone and have a conversation
                        } catch (EOFException ex) {
                            // ex.printStackTrace();
                        }
                    }
                }).start();
            } catch (EOFException eofException) {

            }
        }

在这种情况下，您必须为每个客户端创建服务器实例，并且您的服务器声明应包含与客户端相关的非静态属性，例如:

public class Server {
    private ObjectOutputStream output; // stream data out
    private ObjectInputStream input; // stream data in
    private static ServerSocket server;
    private Socket connection; // socket means set up connetion between 2 computers
...

服务器创建应该在 waitForConnection() 内进行，如下所示:

private static Server waitForConnection() {
    try {
        Socket connection = server.accept();
        return new Server(connection);
    } catch (IOException ioexception) {
        ioexception.printStackTrace();
    }
}

这不是唯一的方法。您可以保留服务器类来负责在同一实例中运行主周期。但在这种情况下，我将创建一些与来自特定客户端的连接相关的附加类处理属性(连接、输入、输出)。

关于java - 编写点对点聊天系统时遇到问题，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41705820/

文章推荐： node.js - Firebase 服务失败但部署工作正常

文章推荐： c++ - 动态转换 C++ 失败

文章推荐： c++ - 从继承自模板的 dll 导出类

文章推荐： java - Java 的对象和类是我的逻辑缺陷

问题
关闭。这个问题是off-topic .它目前不接受答案。想要改进这个问题？ Update the question所以它是on-topic用于堆栈溢出。关闭 12 年前。 Improve thi
问题
我有一个动态网格，其中的数据功能需要正常工作，这样我才能逐步复制网格中的数据。假设在第 5 行中，我输入 10，则从第 6 行开始的后续行应从 11 开始读取，依此类推。如果我转到空白的第一行并输入
问题
我有一个关于我的按钮消失的问题我已经把一个图像作为我的按钮用这个函数动画 function example_animate(px) { $('#cont
php - 将现有帐户链接到 Facebook - 问题/问题
我有一个具有 Facebook 连接和经典用户名/密码登录的网站。目前，如果用户单击 facebook_connect 按钮，系统即可运行。但是，我想将现有帐户链接到 facebook，因为用户可以选
iOS map View 问题/问题
我有一个正在为 iOS 开发的应用程序，该应用程序执行以下操作加载和设置注释并启动核心定位和缩放到位置。 map 上有很多注释，从数据加载不会花很长时间，但将它们实际渲染到 map 上需要一段时间。
ruby-on-rails - Heroku，问题/问题
我被推荐使用 Heroku for Ruby on Rails 托管，到目前为止，我认为我真的会喜欢它。只是想知道是否有人可以帮助我找出问题所在。我按照那里的说明在该网站上创建应用程序，创建并提交
Android WebView setCertificate 问题 SSL 问题
我看过很多关于 SSL 错误的帖子和信息，我自己也偶然发现了一个。我正在尝试使用 GlobalSign CA BE 证书通过 Android WebView 访问网页，但出现了不可信错误。对于大多
c++ - Glew 问题， Unresolved external 问题
我想开始使用 OpenGL 3+ 和 4，但我在使用 Glew 时遇到了问题。我试图将 glew32.lib 包含在附加依赖项中，并且我已将库和 .dll 移动到主文件夹中，因此不应该有任何路径问题。
问题？
我已经盯着这两个下载页面的源代码看了一段时间，但我似乎找不到问题。我有两个下载页面，一个 javascript 可以工作，一个没有。工作:http://justupload.it/v/lfd7不是
jquery - 初级 jQuery 问题(FF/IE 问题)
我一直在使用 jQuery，只是尝试在单击链接时替换文本字段以及隐藏/显示内容项。它似乎在 IE 中工作得很好，但我似乎无法让它在 FF 中工作。我的 jQuery: $(function() {
Android ndk 问题 socket 和 std 问题
我正在尝试为 NDK 编译套接字库，但出现以下两个错误: error: 'close' was not declared in this scope 和 error: 'min' is not a m
java - Selenium 问题 : Select. deselectAll() 导致 iframe 问题
我正在使用 Selenium 浏览器自动化框架测试网站。在测试过程中，我切换到特定的框架，我们将其称为“frame_1”。后来，我在 Select 类中使用了 deselectAll() 方法。不久之
连接到 Heroku PostgreSQL 的 Python 问题 - SSL 问题
我正在尝试通过 Python 创建到 Heroku PostgreSQL 数据库的连接。我将 Windows10 与 Python 3.6.8 和 PostgreSQL 9.6 一起使用。我从“ht
python - 在 Pandas 中创建新列的 np.where() 问题(可能是 NaN 问题？)
我有一个包含 2 列的数据框，我想根据两列之间的比较创建第三列。所以逻辑是:第 1 列 val = 3，第 2 列 val = 4，因此新列值什么都没有第 1 列 val = 3，第 2 列 va
css - 如何调试 iphone 5 中的 css 问题(ui 问题)？
我想知道如何调试 iphone 5 中的 css 问题。我尝试使用 firelite 插件。但是从纵向旋转到横向时，火石占据了整个屏幕。有没有其他方法可以调试 iphone 5 中的 css 问题
CSS 问题，input[id]+label，:hover, 和 :checked 问题
所以我有点难以理解为什么这不起作用。我正在尝试替换我正在处理的示例站点上的类别复选框。我试图让它做以下事情:未选中时以一种方式出现，悬停时以另一种方式出现(选中或未选中)选中时以第三种方式出现(而不是
javascript - 1 javascript/css 问题 2 perl cgi 问题
Javascript CSS 问题: 我正在使用一个文本框来写入一个 div。我使用以下 javascript 获取文本框来执行此操作: function process_input(){
algorithm - NP 中的语言(问题)和 P 中的语言(问题)之间的多项式时间减少
你好，我很难理解 P、NP 和多项式时间缩减的主题。我试过在网上搜索它并问过我的一些 friend ，但我没有得到任何好的答案。我想问一个关于这个话题的一般性问题: 设 A,B 为 P 中的语言(或
python-3.x - 该算法(解决 leetcode 问题 650)(问题 2)的时间复杂度是多少？
你好，我一直在研究 https://leetcode.com/problems/2-keys-keyboard/并想到了这个动态规划问题。您从空白页上的“A”开始，完成后得到一个数字 n，页面上应该
ios - Xcode Server Bot 问题 : warning. 生成服务错误。问题:路径 'some/path' 的存档格式不正确
我正在使用 Cocoapods 和 KIF 在 Xcode 服务器上运行持续集成。我已经成功地为一个项目设置了它来报告每次提交。我现在正在使用第二个项目并收到错误: Bot Issue: warnin

太空宇宙

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

java - 编写点对点聊天系统时遇到问题