Question

java 服务器多线程管理。有多个客户发出连接和断开请求，如何管理服务器的这些线程呢？

就像QQ似的，客户登陆时向服务器发出登陆请求，服务器会把该好友上线的消息发给其好友客户，客户下线时服务器也要断开连接并发给其好友，这种情况的线程是怎么管理，如何实现呢？

Answer 1

原理是这样的，服务器端有一个客户端管理器，负责管理所有连接进来的客户端，另外还需要为这个客户端管理器注册一个监听器，监听客户端的连接与断开两个动作，有客户端连接进来，就会触发监听器，监听器获取该客户端的在线好友列表，向在线的好友推送上线提醒消息，客户端断开时，也会出发监听器，监听器获取该客户端的在线好友列表，向在线的好友推送下线提醒消息

追问

这个监听器的概念不错，不过这个管理器能具体说下，不知道这里面的线程如何管理，因为上线时创建个，下线时又要关闭，但还要给所有链接这的线程发消息。。。谢谢啦！

追答

你能想到反复的创建和销毁线程，这个时候，你就可以想想数据库连接池、线程池的概念了，客户端就不说了，服务器端是可以对资源优化的，至于你说的给所有链接这的线程发消息是不对的，咱们写java程序不可能到那么底层的，到不了线程通讯这一层，我们是在面向对象编程，服务器端管理的客户端对象肯定要有处理消息的能力，对象之间通讯没得问题的

追问

我想的是客户端连接服务器时用SOCKET连接，服务器开启个线程与之通信。每个过程都是这样的连接。这样，多个线程就对应着多个客户端，上线或下线时应该就是服务器通过线程给别的客户端发消息吧？这样客户端断开，线程结束，怎么知道哪些线程是连接着的呢？（线程池没用过。。。）可以实现这个功能吗？

追答

哦，你这是做一个简单聊天室类似的东西吧，上线的所有客户端之间，都能互相通讯，以前我们也做过
不过你的思想没转变过来，我们是面向对象的编程，服务器端必须管理一个与客户端对应的东西（你的意思是线程），而我觉得应该是一个对象，这个对象有通讯的能力就够额
线程池这里是可以用的，而且很简单，jdk自带的就有，按照你的需求，貌似没必要扩展自己的线程池，我贴一段用法
/** 线程池 **/
private ExecutorService threadPool;
private ClientManager(){
this.threadPool = Executors.newFixedThreadPool(10);
}
public void execute(ClientRequestAbs req) {
//提交到线程池
threadPool.execute(req);
}
//这里要求ClientRequestAbs实现Runnable接口就行了

再看一下官方API
public interface Executor {
/**
* 在未来某个时间执行给定的命令。该命令可能在新的线程、已入池的线程
* 或者正调用的线程中执行，这由Executor实现决定。
*/
void execute(Runnable command);
}

追问

非常感谢，非常专业啊！
再问下，ClientRequestAbs也实现一个对Client上线消息的监听吧，然后每个ClientRequestAbs都把这个消息发给对应的Client？我之前确实把他当成线程了，因为感觉是线程直接参与通信的。这样是把每个线程的实现放在对象里面了，先new出一个ClientRequestAbs监听Client的连接请求吧？这样就涉及到对ClientRequestAbs的管理了，因为你不知道有多少客户来连接。

追答

不是的哈，ClientRequestAbs是每当客户端有连接进来的时候，服务器端都会创建的一个对象，用来与客户端通讯，他是与客户端相对应的
我认为监听器是注册在ClientManager上的，他管理所有的ClientRequestAbs，只有他才知道所有的与客户端通讯的对象
监听器的话，请看下面的代码
public interface ClientListener {
/**
* 某个客户端连接进来时，触发这个方法
* 通知ClientManager管理的其他ClientRequestAbs对象，xxx连接进来了
*/
public void connect(ClientRequestAbs req);

/**
* 某个客户端断开连接时，触发这个方法
* 通知ClientManager管理的其他ClientRequestAbs对象，xxx断开连接了
*/
public void disConnection(ClientRequestAbs req);
}
我只写了一个大概的接口哈，实现你自己完成，如果还需要监听其他事件，根据实际情况自己加方法，这两个方法是必须有的

Answer 2

“客户下线时服务器也要断开连接并发给其好友”

除了这个处理，别的不需要处理

追问

客户上线时也要发消息吧，很多用户连接断开，服务器也就要创建关闭，感觉这个过程挺繁琐的，能提供下思路吗？谢谢了！另外QQ服务器也是类似的机制吗，那得多少线程啊

追答

连接是不用管的，只是做你必需处理的事情，如上线提醒、下线提醒

Answer 3

我觉得.可能还有种思路...就是每个客户端都是一个服务端.你发信息给好友时,好友的机器就相当于服务端,好友发你时,你的就相当于是服务端..这样子.

追问

还有，监听器的实现能给些提示吗，因为每个Client连接要new 一个ClientRequestAbs，当一个Client断开时，监听器怎么得到这个消息，并在ClientRequestAbs做出反应呢？
细想又有点晕了。。。麻烦了啊！刚才字数受限了