package com.ilucky.mina.server;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.executor.ExecutorFilter;
import org.apache.mina.filter.executor.OrderedThreadPoolExecutor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
import java.net.InetSocketAddress;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
/**
* @author IluckySi
* @date 20140528
*/
public class MinaServer {
public static final String HOST = "127.0.0.1";
private static final int PORT = 10061;
private static final int BUFFER_SIZE = 8192;
private static final ThreadFactory THREAD_FACTORY = new ThreadFactory() {
public Thread newThread(final Runnable r) {
return new Thread(null, r, "MinaThread2", 64 * 1024);
}
};
public static void main(String[] args) {
try {
//创建服务.
NioSocketAcceptor acceptor = new NioSocketAcceptor(Runtime.getRuntime().availableProcessors() + 1);
//设置缓冲大小.
acceptor.getSessionConfig().setReceiveBufferSize(BUFFER_SIZE);
//添加线程池.
OrderedThreadPoolExecutor executor = new OrderedThreadPoolExecutor(0, 1000, 60, TimeUnit.SECONDS, THREAD_FACTORY);
acceptor.getFilterChain().addLast("threadPool", new ExecutorFilter(executor));
//添加消息过滤器.
acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new XMLProtocolCodecFactory(4)));
//添加业务处理器.
acceptor.setHandler(new MinaServerIoHandler());
//绑定端口.
acceptor.bind(new InetSocketAddress(HOST, PORT));
System.out.println("mina server启动成功!");
} catch (Exception e) {
System.out.println("mina server启动失败!");
}
}
}
/**
输出结果:
mina server启动成功!
log4j:WARN No appenders could be found for logger (org.apache.mina.filter.executor.OrderedThreadPoolExecutor).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
服务器收到客户端返回的消息<?xml version="1.0" encoding="UTF-8"?>
<root><head><author>IluckySi</author><date>20140717 20:35:14</date></head></root>
*/
mina学习基础-入门实例-传输定长报文(三)
5星 · 超过95%的资源 需积分: 31 192 浏览量
2014-07-17
21:17:20
上传
评论
收藏 2.28MB RAR 举报 
mina学习基础-入门实例-传输定长报文(三).rar （48个子文件） 
mina学习基础-入门实例-传输定长报文(三) mina-client 
.project 2KB .mymetadata 306B src com ilucky mina client MinaClientHandler.java 477B MinaClient.java 2KB WebRoot WEB-INF classes com ilucky mina client MinaClient.class 3KB MinaClientHandler.class 1KB lib 
slf4j-api-1.6.4.jar 25KB mina-core-2.0.7.jar 630KB log4j-1.2.17.jar 478KB slf4j-log4j12-1.7.3.jar 9KB web.xml 404B index.jsp 834B META-INF MANIFEST.MF 36B .myeclipse .settings org.eclipse.wst.jsdt.ui.superType.container 49B org.eclipse.wst.common.project.facet.core.xml 252B org.eclipse.jdt.core.prefs 395B org.eclipse.wst.jsdt.ui.superType.name 6B org.eclipse.wst.common.component 471B .jsdtscope 500B .classpath 605B mina-server .project 2KB .mymetadata 306B src com ilucky mina server XMLProtocolDecoder.java 1KB XMLProtocolEncoder.java 1KB MinaServer.java 2KB XMLProtocolCodecFactory.java 864B MinaServerIoHandler.java 608B WebRoot WEB-INF classes com ilucky mina server MinaServer$1.class 738B XMLProtocolCodecFactory.class 1KB MinaServer.class 3KB XMLProtocolDecoder.class 2KB XMLProtocolEncoder.class 2KB MinaServerIoHandler.class 1KB lib slf4j-api-1.6.4.jar 25KB mina-core-2.0.7.jar 630KB dom4j-1.6.1.jar 307KB log4j-1.2.17.jar 478KB slf4j-log4j12-1.7.3.jar 9KB web.xml 404B index.jsp 834B META-INF MANIFEST.MF 36B .myeclipse .settings org.eclipse.wst.jsdt.ui.superType.container 49B org.eclipse.wst.common.project.facet.core.xml 252B org.eclipse.jdt.core.prefs 395B org.eclipse.wst.jsdt.ui.superType.name 6B org.eclipse.wst.common.component 471B .jsdtscope 500B .classpath 529B
评论6
最新资源