isClear = Message_Array.size() > 0 false : true;
}
}
}
}
//--- CreateServerThread
class CreateServerThread extends Thread{
private Socket client;
private BufferedReader in;
private PrintWriter out;
private String Username;
public CreateServerThread(Socket s) throws IOException{
client = s;
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new PrintWriter(client.getOutputStream(), true);
out.println("--- Welcome to this chatroom ---");
out.println("Input your nickname:");
start();
}
public void sendMessage(String msg){
out.println(msg);
}
public void run(){
try{
int flag = 0;
Thread_Counter++;
String line = in.readLine();
while (!line.equals("bye")){
if (line.equals("l")){
out.println(listOnlineUsers());
line = in.readLine();
continue;
}
if (flag++ == 0){
Username = line;
User_List.add(Username);
out.println(listOnlineUsers());
Threader.add(this);
pushMessage("[< " + Username + " come on in >]");
}else{
pushMessage("<" + Username + ">" + line);
}
line = in.readLine();
}
out.println("--- See you, bye! ---");
client.close();
}catch (IOException e){
}finally{
try{
client.close();
}catch (IOException e){}
Thread_Counter--;
Threader.remove(this);
User_List.remove(Username);
pushMessage("[< " + Username + " left>]");
}
}
private String listOnlineUsers(){
String s ="-+- Online list -+-1512";
for (int i = 0; i < User_List.size(); i++){
s += "[" + User_List.get(i) + "]1512";
}
s += "-+---------------------+-";
return s;
}
private void pushMessage(String msg){
Message_Array.addLast(msg);
isClear = false;
}
}
}
这就是程序运行后，多用户登陆并且输入信息后的屏幕。实现了信息的实时广播。用户输入"l"就可以列出在线人员表。
1 封装一个 jar 包
2 java xxx.jar 开启一个 socket server
3 socket 服务接受一个字符串，返回字符串的长度给客户端
3 写一个 ruby client 看看是否可以正常访问 socket