Apache的Mina简单实例
发布时间:2020-05-24 15:32:04 所属栏目:Java 来源:互联网
导读:Apache的Mina简单实例
|
下面是脚本之家 jb51.cc 通过网络收集整理的代码片段。 脚本之家小编现在分享给大家,也给大家做个参考。 // 创建客户端连接器.
NioSocketConnector connector = new NioSocketConnector();
connector.getFilterChain().addLast("logger",new LoggingFilter());
// 设置编码过滤器
connector.getFilterChain().addLast(
"codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"))));
connector.setConnectTimeout(30);
// 设置事件处理器
connector.setHandler(new ClientHandler());
// 建立连接
ConnectFuture cf = connector.connect(new InetSocketAddress("127.0.0.1",9100));
// 等待连接创建完成
cf.awaitUninterruptibly();
// 发送消息
cf.getSession().write("hello");
// 等待连接断开
cf.getSession().getCloseFuture().awaitUninterruptibly();
connector.dispose();
IoAcceptor acceptor = new NioSocketAcceptor();
acceptor.getFilterChain().addLast("logger",new LoggingFilter());
// 指定编码过滤器
acceptor.getFilterChain().addLast(
"codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"))));
// 指定业务逻辑处理器
acceptor.setHandler(new ServerHandler());
// 设置端口号
acceptor.setDefaultLocalAddress(new InetSocketAddress(9100));
// 启动监听
acceptor.bind();
server 处理器
class ServerHandler extends IoHandlerAdapter
{
@Override
public void sessionCreated(IoSession session)
{
// 显示客户端的ip和端口
System.out
.println(session.getRemoteAddress().toString() + " service");
}
@Override
public void messageReceived(IoSession session,Object message)
throws Exception
{
String str = message.toString();
if (str.trim().equalsIgnoreCase("hello"))
{
// System.out.println(str + " client sent : hello");
// 结束会话
session.close();
return;
}
Date date = new Date();
// 返回当前时间的字符串
session.write(date.toString());
}
}
以上是脚本之家(jb51.cc)为你收集整理的全部代码内容,希望文章能够帮你解决所遇到的程序开发问题。 如果觉得脚本之家网站内容还不错,欢迎将脚本之家网站推荐给程序员好友。 (编辑:安卓应用网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
相关内容
- java – 在Spring-Hibernate项目中初始化实体集合(POJO)的正
- java中volatile不能保证线程安全(实例讲解)
- java – Google Guice:具有参数的提供程序
- Android 再按一次退出应用的代码
- java – 如何识别字符串是否包含不能使用utf8-mb4字符集存储
- android获取SD卡的状态
- Java – 将文件从资源管理器移动到Java GUI – 这是什么类型
- drools – 在TaskClient上调用activate方法时获取java.lang
- 有什么方法可以强制类在Java中使用public static final字段
- java – 我在哪里需要将UI初始化代码放在IntelliJ Idea插件
