日期:2014-05-16 浏览次数:21199 次
package com.lrcx.ky.server;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import java.util.concurrent.Executors;
import org.apache.mina.core.service.IoServiceStatistics;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.executor.ExecutorFilter;
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
import com.lrcx.ky.env.SysEnv;
public class TcpServer {
private int port = 8292;
private int idleTime = 1800;
private int bufferSize = 1024;
private SocketAcceptor acceptor;
public void start() {
acceptor = new NioSocketAcceptor(Runtime.getRuntime().availableProcessors() + 1);
TextLineCodecFactory lineCodec = new TextLineCodecFactory(Charset
.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(),
LineDelimiter.WINDOWS.getValue());
lineCodec.setDecoderMaxLineLength(2*1024*1024);
lineCodec.setEncoderMaxLineLength(2*1024*1024);
acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(lineCodec));
acceptor.getFilterChain().addLast("exceutor", new ExecutorFilter(Executors.newCachedThreadPool()));
acceptor.setHandler(new TcpHandler());
acceptor.setReuseAddress(true);
acceptor.setBacklog(10240);
acceptor.getSessionConfig().setReuseAddress(true);
acceptor.getSessionConfig().setReadBufferSize(bufferSize);
acceptor.getSessionConfig().setReceiveBufferSize(bufferSize);
acceptor.getSessionConfig().setTcpNoDelay(true);
acceptor.getSessionConfig().setSoLinger(-1);
// 单位秒
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, idleTime);
try {
acceptor.bind(new InetSocketAddress(port));
} catch (IOException e) {
e.printStackTrace(); System.exit(0);
}
}
public void stop() {
acceptor.dispose();
}
}
package com.lrcx.ky.server;
import net.sf.json.JSONObject;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
public class TcpHandler extends IoHandlerAdapter {
@Override
public void messageReceived(IoSession session, Object message)
throws Exception {
JSONObject request = JSONObject.fromObject(message.toString());
// 根据传来的数据进行处理
System.out.println(request);
}
@Override
publ