1. socket通信：有客户端和效劳端的socket代码。
2. 多线程：客户端和效劳端各用一线程发送信息；效劳端另有一监听线程， 用于把超时的信息删除。
这里应用到了同步， 使两个线程可以操作同一个map。
代码：（类全在同一个包内）
server端：
import java. io. BufferedReader;
import java. io. InputStreamReader;
import java. io. PrintWriter;
import java. ServerSocket;
import java. Socket;
import java. util. Collections;
import java. util. concurrent. TimeUnit;
import java. util. HashMap;
import java. util. Map;
public class ServerNet {
// 以毫秒为单位
private final static long timeLimit = 10000 ;
private MapString, String map = Collections. synchronizedMap(new HashMapString, String());
public void ServerSocketNet(){
try{
ServerSocket ss = new ServerSocket(6060);
Socket s = ss. accept();
// 用于获取客户端传输来的信息
BufferedReader buff = new BufferedReader(new InputStreamReader(s. getInputStream()));
// 用于获取效劳端预备响应的信息
BufferedReader in = new BufferedReader(new InputStreamReader(System. in));
// 发送效劳端预备响应的信息
PrintWriter pw = new PrintWriter(s. getOutputStream(), true);
pw. println("您已经成功树立连接!");
new ServerOutNet(pw, in);
new ServerTimeListener(map, timeLimit);
// 显示客户端的传输来的信息
while(true){
String str = buff. readLine();
if(str. equals("exit")){
break;
}else{
map. put(ServerHelper. getInstance(). getMapKey(), str);
System. out. println(str + " map. size: " + map. size());
}
System. out. println("To Client:");
Thread. sleep(100);
}
s. close();
}catch(Exception e){
e. printStackTrace();
}
}
public static void main(String[] args){
new ServerNet(). ServerSocketNet();
}
}
/**
* server发送线程 向客户端发送响应信息
* @author ids-user
*
*/
class ServerOutNet extends Thread{
private PrintWriter printWriter;
private BufferedReader bufferedReader;
ServerOutNet(PrintWriter pw, BufferedReader in){
this. printWriter = pw;
this. bufferedReader = in;
start();
}
public void run(){
while(true){
try{
String inStr = bufferedReader. readLine();
if(inStr.
姿美堂 equals("exit")){
printWriter. close();
bufferedReader. close();
break;
}else{
printWriter. println("From Server: " + inStr);
}
sleep(300);
}catch(Exception e){
printWriter = null;
bufferedReader = null;
throw new RuntimeException(e);
}
}
}
}
// 时间监听线程类。
class ServerTimeListener extends Thread{
private long timeLimit;
MapString, String map = new HashMapString, String();
// 单例
// private ServerTimeListener(){}
// private final static ServerTimeListener stl = new ServerTimeListener();
// public static ServerTimeListener getInstance(){
// return stl;
// }
ServerTimeListener(MapString, String map , long timeLimit){
this. map = map;
this. timeLimit = timeLimit;
start();
}
