src/cn/jysqq/server/serverModule/QQServerHandler/QQServerTextHandler.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package cn.jysqq.server.serverModule.QQServerHandler;

import java.util.Map;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

import cn.jysqq.message.BaseMessage;
import cn.jysqq.message.LoginMessage;
import cn.jysqq.message.MessageType;
import cn.jysqq.message.SysMessage;
import cn.jysqq.server.serverLog.QQLoger;
import cn.jysqq.server.serverModule.*;
import cn.jysqq.server.serverProcess.ServerReceivedMessageProcess;

/**
 * 
 * @author 胡海亮  qq：249782944
 * 项目：jinyaostarQQ
 * 时间：2009-7-20下午09:30:54
 * 
 * 服务器的 聊天消息 处理类
 */
public class QQServerTextHandler extends IoHandlerAdapter {
    
	/**
	 * 在消息处理过程中发生地异常时候，所采取的响应方法。
	 */
	public void exceptionCaught(IoSession session, Throwable throwable) throws Exception {
		 
	}
	/**
	 * 当服务器接收到消息的时候，所采取的响应方法。
	 */
	public void messageReceived(IoSession session, Object message) throws Exception {
		
		ServerReceivedMessageProcess messageProcess=new ServerReceivedMessageProcess();
		BaseMessage baseMessage=(BaseMessage)message;
		QQLoger.INFO("服务器收到的消息为："+baseMessage);
		
		if(baseMessage.getMsgType()==MessageType.LoginMessage_Type){
			LoginMessage loginMessage=(LoginMessage)baseMessage;
			QQLoger.INFO("服务器收到登入消息，登入者为："+loginMessage.getOwerQQ());
			UserConnect userConnect=new UserConnect();
			userConnect.setTextTempSession(session);
			loginMessage.setLoginID(loginMessage.getOwerQQ()+session.hashCode());
			QQServer.getQQServerInstance().addUserConnect(loginMessage.getLoginID(),userConnect);
			userConnect.getTextTempSession().setAttribute("owerQQ",baseMessage.getSrcQQ());
			userConnect.getTextTempSession().setAttribute("sessionID",session.hashCode());
			messageProcess.processMessage(loginMessage);
			return;
		}
			messageProcess.processMessage(baseMessage);
	}
	/**
	 * 当服务器发送消息的时候，所采取的响应方法。
	 */
	public void messageSent(IoSession session, Object message) throws Exception {
//		QQLoger.INFO("服务器发送了消息："+message);
	}