/** *记录会话接收信息时的信息,然后将该信息传递到过滤器链中的下一个过滤器 */ public void messageReceived(NextFilternextFilter,IoSessionsession, Objectmessage) { if(SessionLog.isInfoEnabled(session)) { SessionLog.info(session,"RECEIVED:"+message); } nextFilter.messageReceived(session,message); }
Mina_IoFilter类图
public class ServerMain { public static void main(String[] args) throws IOException { SocketAddressaddress = new InetSocketAddress("localhost",4321); IoAcceptor acceptor = newSocketAcceptor(); IoServiceConfig config = acceptor.getDefaultConfig(); //配置数据的编解码器 config.getFilterChain().addLast("codec", newProtocolCodecFilter(newObjectSerializationCodecFactory())); //绑定服务器端口 acceptor.bind(address,newServerHandler()); System.out.println("服务器开始在8000端口监听......."); } }
public class ServerHandler extends IoHandlerAdapter { //创建会话 public void sessionOpened(IoSessionsession) throws Exception { System.out.println("服务器创建了会话"); session.write("服务器创建会话时发送的信息。"); } //发送信息 public void messageSent(IoSessionsession,Objectmessage) throws Exception { } //接收信息 public void messageReceived(IoSessionsession,Objectmessage) throwsException { } }
public class ClientMain { public static void main(String[] args) { SocketAddress address = new InetSocketAddress("localhost",4321); IoConnector connector = new SocketConnector(); IoServiceConfig config = connector.getDefaultConfig(); //配置数据的编解码器 config.getFilterChain().addLast("codec", newProtocolCodecFilter(newObjectSerializationCodecFactory())); config.getFilterChain().addLast("logger",newLoggingFilter()); //连接到服务器 connector.connect(address,newClientHandler()); System.out.println("已经连接到了服务器"+address); } }
public class ClientHandler extends IoHandlerAdapter { //发送信息 public void messageSent(IoSessionsession,Objectmessage) throwsException { } //接收信息 public void messageReceived(IoSessionsession,Objectmessage) throwsException { System.out.println("客户端接收到的服务器的信息是"+message); } }
//配置数据的编解码器 config.getFilterChain().addLast("codec", newProtocolCodecFilter(newObjectSerializationCodecFactory()));
//配置数据的编解码器 config.getFilterChain().addLast("codec", newProtocolCodecFilter(newObjectSerializationCodecFactory())); config.getFilterChain().addLast("logger",newLoggingFilter());//添加日志工具
//添加日志工具 config.getFilterChain().addLast("logger",newLoggingFilter()); //配置数据的编解码器 config.getFilterChain().addLast("codec", newProtocolCodecFilter(newObjectSerializationCodecFactory()));
来源:即时通讯网 - 即时通讯开发者社区!
轻量级开源移动端即时通讯框架。
快速入门 / 性能 / 指南 / 提问
轻量级Web端即时通讯框架。
详细介绍 / 精编源码 / 手册教程
移动端实时音视频框架。
详细介绍 / 性能测试 / 安装体验
基于MobileIMSDK的移动IM系统。
详细介绍 / 产品截图 / 安装体验
一套产品级Web端IM系统。
详细介绍 / 产品截图 / 演示视频
连续任职达3个月以上的合格正式版主
Copyright © 2014-2024 即时通讯网 - 即时通讯开发者社区 / 版本 V4.4
苏州网际时代信息科技有限公司 (苏ICP备16005070号-1)
Processed in 0.125000 second(s), 39 queries , Gzip On.