📄 chatroomserver.java
字号:
package day23;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashSet;
public class ChatRoomServer {
private ServerSocket ss;
private HashSet<Socket> allSockets;
public ChatRoomServer(){
try {
ss=new ServerSocket(8888);
allSockets=new HashSet<Socket>();
} catch (IOException e) {
e.printStackTrace();
}
}
public void startService()throws IOException{
while(true){
Socket s=ss.accept();
allSockets.add(s);
new ChatRoomServerThread(s).start();
}
}
class ChatRoomServerThread extends Thread{
private Socket s;
public ChatRoomServerThread(Socket s){
this.s=s;
}
public void run(){
//得到s的输入流,并包装成BufferedReader
//循环不停的从BufferedReader中读取数据。
//每读到一行数据就将这一行数据转发给所有在线的客户端。
// 循环遍历allSockets,得到每一个socket,
// 然后得到该socket的输出流,并包装,再向输出流中写数据。
//
}
}
public static void main(String[] args){
try {
new ChatRoomServer().startService();
} catch (IOException e) {
e.printStackTrace();
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -