首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 软件管理 > 软件架构设计 >

Mina兑现同步设置

2012-07-01 
Mina实现同步设置mina是个异步通信框架,一般使用场景是服务端开发,长连接、异步通信使用mina是及其方便的。?

Mina实现同步设置

mina是个异步通信框架,一般使用场景是服务端开发,长连接、异步通信使用mina是及其方便的。

?

对于并发量不高的场景,现在流行使用短连接:每次连接只进行一次通信,即连接-发送-接收-断开。此种模式的通信客户端,能否使用mina开发?答案是肯定的。

?

mina典型应用,需要实现IoHanlder接口,当收到消息时,此接口的messageReceived方法被触发,开发人员实现此方法即可处理消息。

?

一个同步的客户端,可以不再需要IoHandler,但必须设置如下属性useReadOperation为true。mina会自动添加一个默认的IoHandler实现。

?

下面给出代码片段,一看即明

?

?

?????? NioSocketConnector connector = new NioSocketConnector();

?????? connector.setConnectTimeoutMillis(30000L);

?????? connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new YourCodecFactory()));

?????? SocketSessionConfig cfg = connector.getSessionConfig();

?????? cfg.setUseReadOperation(true);

?????? IoSession session = connector.connect(ip,port).awaitUninterruptibly().getSession();

?

?

现在已实现了连接,接下来就是发送-接收-断开了

?

?

?????????? try {

????????????? // 发送

????????????? session.write(YourMessage).awaitUninterruptibly();

?

????????????? // 接收

????????????? ReadFuture readFuture = session.read();

?

????????????? if (readFuture.awaitUninterruptibly(waitTimeout, TimeUnit.SECONDS)) {

????????????????? YourMessage msg = readFuture.getMessage();

????????????????? // TODO 处理消息

????????????? } else {

????????????????? // 读超时

????????????? }

??? ?????? } finally {

????????????? // 断开

?????? ?????? session.close(true);

?????? ?????? session.getService().dispose();

?????????? }

热点排行