1

好的，所以当我第一次连接时，一切正常。但是当我再次连接时（不停止服务器程序）它说“连接被拒绝：连接”。我以为是因为我只接受一次连接，所以我使用摇摆定时器每 10 毫秒触发一次动作事件，每次动作事件触发时都会将 clientSocket 设置为 serverSocket.accept() (clientSocket = serverSocket.accept( );) 所以这里是代码：

package org.code;

import java.net.*;
import java.io.*;

public class MainClass {
    public static void main(String[] args) {
            new MainClass();
    }


    Socket server = null;
    PrintWriter out = null;

    public MainClass() {
            try {
                    server = new Socket("192.168.0.104", 4444);
                    out = new PrintWriter(server.getOutputStream(), true);

                    out.println("start");

                    out.close();
                    server.close();
            } catch(Exception ex) {ex.printStackTrace();}
    }
}

和：

package org.code;

import java.io.*;
import java.net.*;
import javax.swing.*;

public class MainClass {
    public static void main(String[] args) {
            new MainClass();
    }

    ServerSocket serverSocket = null;

    Socket clientSocket = null;

    BufferedReader in;

    public MainClass() {
            JFrame frame = new JFrame("Minecraft Server Manager v0.1 Server");
            frame.setSize(500,500);
            frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
            frame.setVisible(true);

            try {
                    serverSocket = new ServerSocket(4444);

                    clientSocket = serverSocket.accept();

                    in = new BufferedReader(new            InputStreamReader(clientSocket.getInputStream()));

                    String inputLine;

                    while((inputLine = in.readLine()) != null) {
                            System.out.println(inputLine);
                            if(inputLine.equals("start")) {
                                    System.out.println("Good");
                            }
                            if(inputLine.equals("stop")) {
                                    System.out.println("Bad");
                            }
                    }

                    clientSocket.close();
                    serverSocket.close();
            } catch(Exception ex) {System.err.println("Error: " + ex.getMessage());}
    }
}
4

4 回答 4

1

是的，当前实现的问题在于它只等待第一个客户端，然后服务器停止。检查写入套接字的服务器端，尤其是最后一个条目“支持多个客户端”。通常支持多个客户端的模式如下：

while (true) {
    accept a connection;
    create a thread to deal with the client;
}
于 2013-01-01T22:33:31.930 回答
1

您的代码会在每次请求后关闭 ServerSocket（并且也会停止）。

这更有可能起作用。（我没有测试过，但是有了这个你就得到了场景）

// in your main 
serverSocket = new ServerSocket(4444);

try {
    while (true) { 
        clientSocket = serverSocket.accept();

        Thread t = new ClientSocketThread(clientSocket);
        t.start();
    }
} finally {
    serverSocket.close();
}


class ClientSocketThread extends Thread {
    final Socket clientSocket;

    ClientSocketThread(Socket clientSocket) {
        this.clientSocket = clientSocket;
    }

    public void run() {
        InputStream in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        try
            String inputLine;

            while((inputLine = in.readLine()) != null) {
                System.out.println(inputLine);
                if(inputLine.equals("start")) {
                     System.out.println("Good");
                }
                if(inputLine.equals("stop")) {
                     System.out.println("Bad");
                }
            }
         } finally {
            in.close()
            clientSocket.close();
         }
    }
}
于 2013-01-01T22:41:53.140 回答
0

您的服务器程序（顺便说一句，与客户端程序具有完全相同的类名，这不是很明智），只接受一个连接。

一旦它完成了与第一个客户的对话，它就结束了。您认为它仍在侦听，因为框架仍然可见，但主要方法已结束。

如果要接受多个连续连接，则应该有一个循环。如果你想要多个并行连接，你应该产生线程。

于 2013-01-01T22:35:05.003 回答
0 
clientSocket.close();
serverSocket.close();

问题就在这里。此时关闭服务器套接字是没有意义的，因为您已经完成了一个客户端。

于 2013-01-02T00:33:41.560 回答