Socket编程——怎么实现一个服务器多个客户端之间的连接

时间:2023-03-10 00:44:34
Socket编程——怎么实现一个服务器多个客户端之间的连接
 

 package coreBookSocket;

 import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket; /*
* 这个方法的主要目地是为了用多线程的方法实现网络编程,让多个客户端可以同时连接到一个服务器
*1:准备工作和单个客户端编程类似,先建立服务器端的套接字,同时让服务器那边调用accept()方法来接受服务器端的信息,并且返回一个Socket客户端套接字
*2:这里面定一个while循环主要是为了让多线程能够一直持续的进行下去,为此while循环开始执行的时候都会先建立
* 一个新的线程来处理服务器和客户端之间的连接
*3:同时定一个threadedEchoHandler来实现Runnable接口,而该类的主要作用是为了实现客户端循环通信的demo
* author:by XIA
* data:9.26.2016
*/
public class SimpleServerOfClients {
public static void main(String[] args) throws IOException { int i=1;
ServerSocket server=new ServerSocket(8189);
while(true)
{
Socket client=server.accept();
System.out.println("Spawning "+i);
Runnable r = new threadedEchoHandler(client);
Thread t=new Thread(r);
t.start();
i++;
}
}
}
package coreBookSocket;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner; public class threadedEchoHandler implements Runnable {
private Socket client; public threadedEchoHandler(Socket i) {
client=i;
} @Override
public void run() {
try {
InputStream ins=client.getInputStream();
OutputStream outs=client.getOutputStream();
Scanner in=new Scanner(ins);
PrintWriter out=new PrintWriter(outs, true);
System.out.println("Hello! Enter bye to exit!"); boolean done=false;
while(!done&&in.hasNextLine())
{
String line = in.nextLine();
System.out.println("回应:" + line);
if (line.trim().equalsIgnoreCase("bye"))
{
done=true;
}
}
client.close();
} catch (IOException e) {
e.printStackTrace();
}
} }