if (toRemoveFromList) {
clientProcessors.removeElement(client);
client.toStop();
}
}
}
public static void main(String[] args) {
ChatServer chatServer1 = new ChatServer();
chatServer1.setVisible(true);
System.out.println("Server starting ...");
ServerSocket server = null;
try {
// 服务器端开始侦听
server = new ServerSocket(Constants.SERVER_PORT);
} catch (IOException e) {
System.out.println("Error:" + e);
System.exit(1);
}
while (true) {
// 如果当前客户端数小于MAX_CLIENT个时接受连接请求
if (clientProcessors.size()Constants.MAX_CLIENT) {
Socket socket = null;
try {
// 收到客户端的请求
socket = server.accept();
if (socket != null) {
System.out.println(socket + "连接");
}
} catch (IOException e) {
System.out.println("Error:" + e);
}
// 定义并实例化一个ClientProcessor线程类,用于处理客户端的消息
ClientProcessor c = new ClientProcessor(socket);
if (checkClient(c)) {
// 添加到列表
clientProcessors.addElement(c);
// 如果客户端合法,则继续
int connum = ++ChatServer.activeConnects;
// 在状态栏里显示连接数
String constr = "目前有" + connum + "客户相连";
ChatServer.statusBar.setText(constr);
// 将客户socket信息写入list框
ChatServer.connectInfoList.add(c.clientIP + "连接");
c.start();
// 通知所有客户端用户列表发生变化
notifyRoomPeople();
} else {
//如果客户端不合法
c.ps.println("不允许重复登陆");
disconnect(c, false);
}
} else {
//如果客户端超过了MAX_CLIENT个 , 则等待一段时间再尝试接受请求
try {
Thread.sleep(200);
} catch (InterruptedException e) {
}
}
}
}
}
/**
* 处理客户端发送的请求的线程
*/
class ClientProcessor extends Thread {
//存储一个连接客户端的socket信息
Socket socket;
//存储客户端的连接姓名
String clientName;
//存储客户端的ip信息
String clientIP;
//用来实现接受从客户端发来的数据流
BufferedReader br;
//用来实现向客户端发送信息的打印流
PrintStream ps;
boolean running = true;
/**
* 构造方法
* @param s
*/
public ClientProcessor(Socket s) {
socket = s;
try {
// 初始化输入输出流
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
ps = new PrintStream(socket.getOutputStream());
// 读取收到的信息,第一条信息是客户端的名字、IP信息
String clientInfo = br.readLine();
// 读取信息,根据消息分隔符解析消息
StringTokenizer stinfo = new StringTokenizer(clientInfo, Constants.SEPERATOR);
String head = stinfo.nextToken();
if (head.equals(Constants.CONNECT_IDENTIFER)){
if (stinfo.hasMoreTokens()){
//关键字后的第二段数据是客户名信息
clientName = stinfo.nextToken();
}
if (stinfo.hasMoreTokens()){
//关键字后的第三段数据是客户ip信息
clientIP = stinfo.nextToken();
}
System.out.println(head); //在控制台打印头信息
}
} catch (IOException e) {
System.out.println("Error:" + e);
}
}
/**
* 向客户端发送消息
* @param msg
*/
public void send(StringBuffer msg) {
ps.println(msg);
ps.flush();
}
//线程运行方法
public void run() {
while (running) {
String line = null;
try {
//读取客户端发来的数据流
line = br.readLine();
} catch (IOException e) {
推荐阅读
- linux定向命令,linux 重定向
- 纪实拍摄什么好用呢,纪实摄影拍什么比较好
- 什么牌子路由器速度快,什么牌子路由器网速快
- 单机游戏休闲益智推荐,单机益智休闲小游戏
- 如何写c语言中阶乘函数 c语言中阶乘函数怎么表示
- gis驱动力分析操作,gis驱动页面设置
- 跟着chatgpt学英语,跟着lucy学英语全集
- js控制导入的js,js中导入js
- 关系函数python 关系函数中的不完全函数依赖是