Java 与服务器的连接受限
Java Limited connections to server
我是 java 的新手,尤其是 java 网络,但我想做的是设置服务器(用于游戏)。当两个客户端连接到服务器时,我想拒绝任何其他连接。我可以关闭 ServerSocket 吗?如果 ServerSocked 关闭,那两个已经 运行 作为线程并存储在集合中的连接仍然存在并且能够与服务器通信?我希望你明白我的意思。
这是源代码:
//Server
public synchronized List<ClientThread> getClients(){
return clients;
}
public void run() {
try {
while(true){
Socket clsock = srvsock.accept();
if(getClients().size() == 2){
System.out.println("Too many connections!");
clsock.close();
continue;
}
ClientThread clt = new ClientThread(clsock);
clients.add(clt);
clt.start();
System.out.println("Connection accepted.");
}
} catch (IOException ex) {
ex.printStackTrace(System.err);
}
}
并且使用此代码,我无法在客户端上检测连接是否仍然存在,或者服务器是否已关闭连接。提前致谢。
每次建立连接时,服务器 returns 一个新套接字(当您使用 srvsock.accept() 时)用于下一个连接。所以你可以关闭 "srvsock" 而不会影响 "clsock"。要测试它们是否还活着,请检查此 post How do I check if a Socket is currently connected in Java?。
希望能解决你的问题。
测试客户端代码:
Socket s = new Socket("localhost", 8932);
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
for (int i=0; i<20; i++) {
bw.write(String.valueOf(i));
bw.newLine();
bw.flush();
Thread.sleep(1000);
}
bw.close();
对于 ClientThread:
BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
while (true) {
String misc = in.readLine();
System.out.println(misc);
if (misc==null || misc.length()==0)
break;
}
in.close();
输出:
Connection accepted.
0
Connection accepted.
0
1
Too many connections!
1
2
2
3
所以它按您的预期工作。顺便说一下,实现 Runnable 通常比扩展 Thread 更好 - 请参阅 "implements Runnable" vs. "extends Thread"
我是 java 的新手,尤其是 java 网络,但我想做的是设置服务器(用于游戏)。当两个客户端连接到服务器时,我想拒绝任何其他连接。我可以关闭 ServerSocket 吗?如果 ServerSocked 关闭,那两个已经 运行 作为线程并存储在集合中的连接仍然存在并且能够与服务器通信?我希望你明白我的意思。
这是源代码:
//Server
public synchronized List<ClientThread> getClients(){
return clients;
}
public void run() {
try {
while(true){
Socket clsock = srvsock.accept();
if(getClients().size() == 2){
System.out.println("Too many connections!");
clsock.close();
continue;
}
ClientThread clt = new ClientThread(clsock);
clients.add(clt);
clt.start();
System.out.println("Connection accepted.");
}
} catch (IOException ex) {
ex.printStackTrace(System.err);
}
}
并且使用此代码,我无法在客户端上检测连接是否仍然存在,或者服务器是否已关闭连接。提前致谢。
每次建立连接时,服务器 returns 一个新套接字(当您使用 srvsock.accept() 时)用于下一个连接。所以你可以关闭 "srvsock" 而不会影响 "clsock"。要测试它们是否还活着,请检查此 post How do I check if a Socket is currently connected in Java?。 希望能解决你的问题。
测试客户端代码:
Socket s = new Socket("localhost", 8932);
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
for (int i=0; i<20; i++) {
bw.write(String.valueOf(i));
bw.newLine();
bw.flush();
Thread.sleep(1000);
}
bw.close();
对于 ClientThread:
BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
while (true) {
String misc = in.readLine();
System.out.println(misc);
if (misc==null || misc.length()==0)
break;
}
in.close();
输出:
Connection accepted.
0
Connection accepted.
0
1
Too many connections!
1
2
2
3
所以它按您的预期工作。顺便说一下,实现 Runnable 通常比扩展 Thread 更好 - 请参阅 "implements Runnable" vs. "extends Thread"