Mina NIO Socket个人总结，其中包括重连机制，自定义解码器，需要加入的jar包log4j.jar,mina-core-2.0.1.jar,slf4j-api-1.4.2.jar,slf4j-log4j12-1.4.2.jar,也希望给接触者一些帮助。解码器感觉有点麻烦，各位指教。我的解码器"]"为一条消息的结束标记。后面附源码，如有更好方法请留言。
Server
package com.joe.server;
import java.net.InetSocketAddress;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.demux.DemuxingProtocolCodecFactory;
import org.apache.mina.filter.executor.ExecutorFilter;
import org.apache.mina.filter.executor.OrderedThreadPoolExecutor;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
import com.joe.codec.decoder.MyMessageDecoder;
import com.joe.codec.encoder.MyMessageEncoder;
import com.joe.handler.ServerIoHandler;
/**
* @author joe
*/
public class MyServer {
private NioSocketAcceptor acceptor;
/**
* Constructor
*/
public MyServer() {
try {
acceptor = new NioSocketAcceptor();
acceptor.getFilterChain().addLast("threadPool",
new ExecutorFilter(new OrderedThreadPoolExecutor()));// 设置线程池，以支持多线程
acceptor.getFilterChain().addLast("logger", new LoggingFilter());
/**
* 默认编码器,解码器,遇到\n默认消息结束
* 当然可以加参数指定解码字符，但解码字符会被截掉
* 例如:new TextLineCodecFactory(Charset.forName("UTF-8"),"]","]");
* 则会认为"]"为一条消息结束，遇到"]"则截取
* 比如服务器给你发送的消息是aaaa]aaaa]
* 会收到两条消息：
* 1、aaaa
* 2、aaaa
* 后面的"]"则去掉了
*/
// acceptor.getFilterChain().addLast(
// "codec",
// new ProtocolCodecFilter(new TextLineCodecFactory(Charset
// .forName("UTF-8"))));// 指定编码过滤器
DemuxingProtocolCodecFactory pcf = new DemuxingProtocolCodecFactory();
//自定义编码器
pcf.addMessageEncoder(String.class, new MyMessageEncoder());
//自定义解码器
pcf.addMessageDecoder(new MyMessageDecoder());
ProtocolCodecFilter codec = new ProtocolCodecFilter(pcf);
acceptor.getFilterChain().addLast("codec",codec);// 指定编码过滤器
acceptor.setReuseAddress(true);
acceptor.setHandler(new ServerIoHandler());// 指定业务逻辑处理器
acceptor.setDefaultLocalAddress(new InetSocketAddress(8888));// 设置端口号
acceptor.bind();// 启动监听
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* @param args
*/
public static void main(String[] args) {
new MyServer();
}
}
Server IoHandler
package com.joe.handler;
import org.apache.mina.core.service.IoHandler;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
public class ServerIoHandler implements IoHandler {
public void exceptionCaught(IoSession session, Throwable pArg1)
throws Exception {
}
public void messageReceived(IoSession session, Object obj) throws Exception {
//收到的信息
System.out.println(obj.toString());
}
public void messageSent(IoSession session, Object pArg1) throws Exception {
}
public void sessionClosed(IoSession session) throws Exception {
}
public void sessionCreated(IoSession session) throws Exception {
}
public void sessionIdle(IoSession session, IdleStatus pArg1) throws Exception {
}
public void sessionOpened(IoSession session) throws Exception {
session.write("[Server: Client,I'm server.][Server: Client,I'm server.]");
}
}
client
package com.joe.client;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.demux.DemuxingProtocolCodecFactory;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
import com.joe.codec.decoder.MyMessageDecoder;
import com.joe.codec.encoder.MyMessageEncoder;
import com.joe.handler.ClientIoHandler;
/**
* @author joe
*/
public class MyClient {
private NioSocketConnector connector;
/**
* Constructor
*/
public MyClient() {
connector = new NioSocketConnector();
/**
* 设置信息交换的IoHandler,负责接收和发送信息的处理
*/
connector.setHandler(new ClientIoHandler());
//配置过滤器
DefaultIoFilterChainBuilder chain = connector.getFilterChain();
//增加日志过滤器
chain.addLast("logger", new LoggingFilter());
//增加字符编码过滤器以及设置编码器和解码器
//chain.addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
/**
* 默认编码器,解码器,遇到\n默认消息结束
* 当然可以加参数指定解码字符，但解码字符会被截掉
* 例如:new TextLineCodecFactory(Charset.forName("UTF-8"),"]","]");
* 则会认为"]"为一条消息结束，遇到"]"则截取
* 比如服务器给你发送的消息是aaaa]aaaa]
* 会收到两条消息：
* 1、aaaa
* 2、aaaa
* 后面的"]"则去掉了
*/
// acceptor.getFilterChain().addLast(
// "codec",
// new ProtocolCodecFilter(new TextLineCodecFactory(Charset
// .forName("UTF-8"))));// 指定编码过滤器
DemuxingProtocolCodecFactory pcf = new DemuxingProtocolCodecFactory();
//自定义编码器
pcf.addMessageEncoder(String.class, new MyMessageEncoder());
//自定义解码器
pcf.addMessageDecoder(new MyMessageDecoder());
ProtocolCodecFilter codec = new ProtocolCodecFilter(pcf);
chain.addLast("codec",codec);// 指定编码过滤器
//设置默认连接的地址和端口
connector.setDefaultRemoteAddress(new InetSocketAddress("localhost", 8888));
/**
* 重连机制
* 如果没有连接，则过30 * 1000毫秒客户端会尝试重新连接服务器
* 如果连接，则下面的代码不会执行
*/
new Timer().schedule(new TimerTask() {
@Override
public void run() {
if (null != connector && !connector.isActive()) {
try {
//尝试连接默认的地址和端口
ConnectFuture connFuture = connector.connect();
connFuture.awaitUninterruptibly();
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
}
}, new Date(), 30 * 1000);
}
/**
* @param args
*/
public static void main(String[] args) {
new MyClient();
}
}
Client IoHandler
package com.joe.handler;
import org.apache.mina.core.service.IoHandler;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
public class ClientIoHandler implements IoHandler {
public void exceptionCaught(IoSession session, Throwable throwable)
throws Exception {
}
public void messageReceived(IoSession session, Object obj) throws Exception {
//收到的内容
System.out.println(obj.toString());
}
public void messageSent(IoSession session, Object obj) throws Exception {
}
public void sessionClosed(IoSession session) throws Exception {
}
public void sessionCreated(IoSession session) throws Exception {
}
public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
}
public void sessionOpened(IoSession session) throws Exception {
session.write("[Client: Server,I'm client.][Client: Server,I'm client.]");
}
}
自定义编码器(MessageEncoder)
package com.joe.codec.encoder;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolEncoderOutput;
import org.apache.mina.filter.codec.demux.MessageEncoder;
/**
* @author joe
* @param <T>
*/
public class MyMessageEncoder implements MessageEncoder<String> {
/**
* 编码器未做任何处理
* @param session
* @param msg
* @param out
* @throws Exception
*/
public void encode(IoSession session, String msg,
ProtocolEncoderOutput out) throws Exception {
IoBuffer buf = IoBuffer.allocate(msg.getBytes().length);
buf.put(msg.getBytes());
buf.flip();
out.write(buf);
}
}
自定义解码器(MessageDecoder)
package com.joe.codec.decoder;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;
import org.apache.mina.filter.codec.demux.MessageDecoder;
import org.apache.mina.filter.codec.demux.MessageDecoderResult;
/**
* @author joe
*/
public class MyMessageDecoder implements MessageDecoder {
//消息的开始
private int flag = 0;
//消息的长度
private int length = 0;
//消息的结尾
private int flaglast = 0;
//不是第一条消息
private boolean notfirstmessage = false;
public MessageDecoderResult decodable(IoSession session, IoBuffer in) {
int rem = in.remaining();
int fornumber;
byte aa;
if (notfirstmessage) {
flag++;
fornumber = rem + flag;
} else {
flag = 0;
fornumber = rem + flag;
}
try {
for (int i = flag; i < fornumber; i++) {
aa = in.get(i);
if (']' == aa) {
flaglast = flag;
flag = i;
length = flag - flaglast;
notfirstmessage = true;
return MessageDecoderResult.OK;
}
}
} catch (Exception e) {
e.printStackTrace();
}
notfirstmessage = false;
return MessageDecoderResult.NEED_DATA;
}
public MessageDecoderResult decode(IoSession session, IoBuffer in,
ProtocolDecoderOutput out) throws Exception {
try {
if (length == 0 || length == 1) {
in.get();
out.write("");
return MessageDecoderResult.OK;
}
length++;
byte[] result = new byte[length];
for (int i = 0; i < length; i++) {
result[i] = in.get();
}
if (0 == in.remaining()) {
notfirstmessage = false;
}
String cont = new String(result, "us-ascii");
out.write(cont.trim());
return MessageDecoderResult.OK;
} catch (Exception e) {
e.printStackTrace();
}
return MessageDecoderResult.OK;
}
public void finishDecode(IoSession session, ProtocolDecoderOutput out)
throws Exception {
}
}
分享到：
相关推荐
NULL 博文链接：https://ginge.iteye.com/blog/363178
mina简单示例，Apache Mina Server 是一个网络通信应用框架，也就是说，它主要是对基于TCP/IP、UDP/IP协议栈的通信...Mina 提供了事件驱动、异步（Mina 的异步IO 默认使用的是JAVA NIO 作为底层支持）操作的编程模型。
niosocket及其开源框架MINA学习总结收集.pdf
Ioserver java Nio socket 框架 是个不错的NIO 通讯框架，本来想学习mina框架，看了看mina的源码太头痛，本人觉得看懂了Ioserver 再看mina的框架，想多的学习 java NIO 的也可以下载 看看，很值得学习啊！！！
常见NIO开源框架（MINA、xSocket）学习 基于io包的阻塞式socket通信代码简单，在连接数很少的情况下是一个不错的选择。不过实际应用中一个socket服务器采用传统的阻塞式socket方式通信可能会是一场灾难，一路...
socket的tcp/udp(多播) nio的tcp/udp mina 均有服务端/客服端
Sun NIO 要高出约 10%）。由于这一系列的重大改进，使得 2.0.x 成为十分令人期待的一个版本 我们在惊叹 MINA 可以带来多么大便利的同时，还不得不为其卓越的性能而骄傲，据称使用MINA开发服务器程序的性能已经...
NULL 博文链接：https://sariel.iteye.com/blog/470383
基于MINA构建简单高性能的NIO应用,提出了JAVA NIO在MINA上的简单应用
Java_NIO基础教程、MINA教程, 并附上基于springboot 整合mina的基础平台框架，可以直接使用，也可以借鉴下
NULL 博文链接：https://shiwujie.iteye.com/blog/1045272
jaca视频教程 jaca游戏服务器端开发 Netty NIO AIO Mina视频教程 课程目录： 一、Netty快速入门教程 01、第一课NIO 02、第二课netty服务端 03、第三课netty客户端 04、第四课netty线程模型源码分析(一) 05、...
也可以提供JAVA 对象的序列化服务、虚拟机管道通信服务等），Mina 可以帮助我们快速开发高性能、高扩展性的网络通信应用，Mina 提供了事件驱动、异步（Mina 的异步IO 默认使用的是JAVA NIO 作为底层支持）操作的编程...
最近使用Mina开发一个Java的NIO服务端程序，因此也特意学习了Apache的这个Mina框架。 首先，Mina是个什么东西？看下官方网站（http://mina.apache.org/）对它的解释： Apache的Mina（Multipurpose Infrastructure ...
Apache的Mina（Multipurpose Infrastructure Networked Applications）是一个网络应用框架，可以帮助用户开发高性能和... 网络套接字（networking socket）类库 事件驱动的异步API(注意：在JDK7中也新增了异步API)
mina服务端工程例子包括相关源码，实现了socket 的nio
Apache Mina Server 是一个网络通信应用框架，也就是说，它主要是对基于 TCP/IP、UDP/IP协议栈的通信...学习本文档，需要你已掌握 JAVA IO、JAVA NIO、JAVA Socket、JAVA 线程及并发库(java.util.concurrent.*)的知识。
一个网络应用框架，可以帮助用户开发高性能和高扩展性的网络应用程序；它提供了一个抽象的、事件...Apache Mina也称为： NIO框架 客户端/服务端框架（典型的C/S架构） 网络套接字（networking socket）类库
mina是一款优秀的开源通信软件，java nio模式