基于netty的聊天室

netty4 部分代码

package com.cn.common.core.session;/** * 会话抽象接口 * * */public interface Session {	/**	 * 会话绑定对象	 * @return	 */	Object getAttachment();	/**	 * 绑定对象	 * @return	 */	void setAttachment(Object attachment);	/**	 * 移除绑定对象	 * @return	 */	void removeAttachment();	/**	 * 向会话中写入消息	 * @param message	 */	void write(Object message);	/**	 * 判断会话是否在连接中	 * @return	 */	boolean isConnected();	/**	 * 关闭	 * @return	 */	void close();}

SessionImpl

package com.cn.common.core.session;import io.netty.channel.Channel;import io.netty.util.AttributeKey;/** * 会话封装类 * * */public class SessionImpl implements Session {	/**	 * 绑定对象key	 */	public static AttributeKey

SessionManager

package com.cn.common.core.session;import java.util.Collections;import java.util.Set;import java.util.concurrent.ConcurrentHashMap;import com.cn.common.core.model.Response;import com.cn.common.core.serial.Serializer;import com.cn.common.core.session.Session;import com.google.protobuf.GeneratedMessage;/** * 会话管理者 * * */public class SessionManager {	/**	 * 在线会话	 */	private static final ConcurrentHashMap
      
        onlineSessions = new ConcurrentHashMap<>();	/**	 * 加入	 * @param playerId	 * @param channel	 * @return	 */	public static boolean putSession(long playerId, Session session){		if(!onlineSessions.containsKey(playerId)){			boolean success = onlineSessions.putIfAbsent(playerId, session)== null? true : false;			return success;		}		return false;	}	/**	 * 移除	 * @param playerId	 */	public static Session removeSession(long playerId){		return onlineSessions.remove(playerId);	}	/**	 * 发送消息[自定义协议]	 * @param 
       
        	 * @param playerId	 * @param message	 */	public static 
        
          void sendMessage(long playerId, short module, short cmd, T message){		Session session = onlineSessions.get(playerId);		if (session != null && session.isConnected()) {			Response response = new Response(module, cmd, message.getBytes());			session.write(response);		}	}	/**	 * 发送消息[protoBuf协议]	 * @param 
         
          	 * @param playerId	 * @param message	 */	public static 
          
            void sendMessage(long playerId, short module, short cmd, T message){		Session session = onlineSessions.get(playerId);		if (session != null && session.isConnected()) {			Response response = new Response(module, cmd, message.toByteArray());			session.write(response);		}	}	/**	 * 是否在线	 * @param playerId	 * @return	 */	public static boolean isOnlinePlayer(long playerId){		return onlineSessions.containsKey(playerId);	}	/**	 * 获取所有在线玩家	 * @return	 */	public static Set
           
             getOnlinePlayers() { return Collections.unmodifiableSet(onlineSessions.keySet()); }}