java-线程反社会

2019-11-03 00:01:14 阅读：149 来源： 互联网

标签：multithreading sockets networking java

所以我有两个线程-服务器线程和客户端线程.我可以让服务器写东西,但是它永远不会被客户端读取.这是客户端,服务器以及服务器产生的用于处理客户端连接的线程.

客户端-连接到套接字,然后尝试与服务器进行乒乓球.客户端希望服务器首先与它对话！

public class ClientMain {    
    public static void main(String[] args) throws UnknownHostException, IOException {
        Socket socket = new Socket("localhost", 14285);

        BufferedReader in = null;
        PrintWriter out = null;
        try {
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream());
        } catch(IOException e) {
            Log.write("Error in client thread ");
            Log.write(e);
        }
        while(true) {
        System.out.println("About to read!! :-D");
            String fromServer = in.readLine();
            System.out.println("From server: " + fromServer);
            out.println("PONG");
        }
    }
}

服务器-这是服务器的启动方法.它产生一个用于监视serverSocket的线程,并根据需要产生客户端线程.是的,我意识到在这样的方法中定义类是一种不好的做法,如果不好读,我深表歉意.

public void start() {
    this.running = true;
    // probably could have done this better, but it gets the job done
    class Start implements Runnable {
        Server server;
        Start(Server server) { this.server = server; }
        public void run() {
            while(server.running) {
                try {
                    Socket socket = server.serverSocket.accept();
                    Log.write("Accepted socket");
                    new ClientThread(server,socket).start();
                } catch (IOException e) { e.printStackTrace(); }
            }
        }

    }
    Thread start = new Thread(new Start(this));
    start.start();
}

这是客户端线程-也不是全部.我从套接字获取流,并写入一些数据,直到不再使用为止,然后从客户端获取一些数据.

        public void run() {
            Log.write("Running clientthread");
            BufferedReader in = null;
            PrintWriter out = null;
            try {
                in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                out = new PrintWriter(socket.getOutputStream());

            } catch(IOException e) {
                running = false;
                Log.write("Error in client thread " + getName());
                Log.write(e);
            }
            while(running) {

                try {
                    String message = messageQueue.poll();
                    while(message != null) {
                        out.println(message);
                        Log.write("wrote message: " + message);
                        message = messageQueue.poll();
                    }
                    String input = in.readLine();
                    System.out.println("From client: " + input);
                    server.handle(username,input,this);
                }
                catch(IOException e) {
                    Log.write("Error in client thread " + getName() + " username=" + username);
                    Log.write(e);
                    break;
                }
            }
        }

现在,这就是服务器端输出的内容：

Accepted socket
Running clientthread
wrote message: PING

这向我表明它正在建立连接并写出消息. (为清楚起见,当实例化客户端线程时,PING被填充到messageQueue中,这样一来,总是有必要对客户端说些什么才能开始对话.这就像是害羞线程的破冰器,是吗？)它也向我表明它没有从客户端获得任何回报,因为in.readLine()之后没有任何输出

另外,客户端上唯一的输出是即将读取的通知.那么如何丢失服务器正在写的内容呢？

任何想法表示赞赏！

谢谢！！

解决方法:

我正在猜测,请尝试添加：

out.flush();
out.close();

标签：multithreading,sockets,networking,java
来源： https://codeday.me/bug/20191102/1995122.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java-线程反社会