this.running = false;
}
//线程运行方法
public void run(){
String msg = null;
while (running) {
msg = null;
try {
// 读取从服务器传来的信息
msg = br.readLine();
System.out.println("receive msg: " + msg);
} catch (IOException e) {
System.out.println("Error:" + e);
parent.disconnect();
}
// 如果从服务器传来的信息为空则断开此次连接
if (msg == null) {
parent.listener = null;
parent.soc = null;
parent.peopleList.removeAll();
running = false;
return;
}
//用StringTokenizer类来实现读取分段字符
StringTokenizer st = new StringTokenizer(msg, Constants.SEPERATOR);
//读取信息头即关键字用来识别是何种信息
String keyword = st.nextToken();
if (keyword.equals(Constants.PEOPLE_IDENTIFER)) {
//如果是PEOPLE则是服务器发来的客户连接信息
//主要用来刷新客户端的用户列表
parent.peopleList.removeAll();
//遍历st取得目前所连接的客户
while (st.hasMoreTokens()){
String str = st.nextToken();
parent.peopleList.add(str);
}
} else if (keyword.equals(Constants.MSG_IDENTIFER)) {
//如果关键字是MSG则是服务器传来的聊天信息,
//主要用来刷新客户端聊天信息区将每个客户的聊天内容显示出来
String usr = st.nextToken();
parent.chatContentTextArea.append(usr);
parent.chatContentTextArea.append(st.nextToken("\0"));
parent.chatContentTextArea.append("\r\n");
} else if (keyword.equals(Constants.QUIT_IDENTIFER)) {
//如果关键字是QUIT则是服务器关闭的信息, 切断此次连接
System.out.println("Quit");
try {
running = false;
parent.listener = null;
parent.soc.close();
parent.soc = null;
} catch (IOException e) {
System.out.println("Error:" + e);
} finally {
parent.soc = null;
parent.peopleList.removeAll();
}
break;
}
}
//清除用户列表
parent.peopleList.removeAll();
}
}
}
package Chat;
import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowEvent;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.StringTokenizer;
import java.util.Vector;
import javax.swing.BorderFactory;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JMenu;
import javax.swing.JMenuBar;
import javax.swing.JMenuItem;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.SwingUtilities;
import javax.swing.UIManager;
import javax.swing.border.TitledBorder;
/**
* 聊天室的服务器端程序,GUI界面
*/
public class ChatServer extends JFrame {
// 状态栏标签
static JLabel statusBar = new JLabel();
// 显示客户端的连接信息的列表
static java.awt.List connectInfoList = new java.awt.List(10);
// 保存当前处理客户端请求的处理器线程
static Vector clientProcessors = new Vector(10);
// 当前的连接数
static int activeConnects = 0;
// 构造方法
public ChatServer() {
init();
try {
// 设置界面为系统默认外观
UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
SwingUtilities.updateComponentTreeUI(this);
} catch (Exception e) {
e.printStackTrace();
}
}
private void init(){
this.setTitle("聊天室服务器");
推荐阅读
- java代码实现元素去重,java删除元素
- html5li之间,html5lib
- 为什么ios搜不到曙光英雄,曙光英雄ios什么时候上架
- 在户外体育游戏活动中,户外体育游戏活动中班
- vbnet暂停 vba暂停后继续
- flutter上传图片到服务器,flutter dio上传图片
- chatgpt曲谱,chasing pavements简谱
- java看代码执行顺序 java查看程序执行时间
- 网络电视安装什么韩剧,网络电视安装什么韩剧软件