mina HTTP协议实例

WChao226

浏览: 27820 次
性别:
来自: 重庆

最近访客更多访客>>

yeming471114363

jxm19820907

riitxihc

卖火柴的小驴子

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

java
mina

mina HTTP协议实例 minaHttp编码解码器

minaHTTP请求实例
有的时候我们需要高性能的响应服务，而传统的webService方式，tomcat_Web服务器不能满足我们的要求时，mina是一个很好的选择（netty也很不错）,正是因其快速的处理能力，备受游戏开发者的喜爱、有高性能要求的接口开发者喜爱，本文给出一个mina的HTTP服务实例，编码解码都已写好，可直接测试。

只给出了以部分代码，详细代码请在附件中下载
------------------------------------------------------

测试方法.
启动HttpServer.java服务端

浏览器中输入：
//http://127.0.0.1:8882/execute.do?method=hello&user=eric&pwd=123321&age=23

//服务端输出结果：

2015-09-29 22:34:38  sessionCreated...2015-09-29 10:34:38
2015-09-29 22:34:38  sessionOpened...2015-09-29 10:34:38
context...execute.do
method====hello
user====eric
pwd====123321
age====23
user parameters====1----eric
2015-09-29 22:34:38  sessionClosed...2015-09-29 10:34:38
2015-09-29 22:34:38  messageSent...2015-09-29 10:34:38
//浏览器上显示的响应内容：
wangc response Test测试测试aaa

服务器端（HttpServer.java）：

package com.server;

import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.util.concurrent.Executors;

import org.apache.log4j.Logger;
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.executor.ExecutorFilter;
import org.apache.mina.filter.firewall.BlacklistFilter;
import org.apache.mina.filter.logging.LogLevel;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.SocketSessionConfig;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

import com.GlobalParam;
import com.myProtocols.HttpServerProtocolCodecFactory;

/**
 * 
 * @author wangchao
 * @Version 1.0
 * @date 2015-9-30 上午9:40:37
 */
public class HttpServer {
//	private static final Logger logger = LoggerFactory.getLogger(TcpServer.class);
	private static final Logger logger = Logger.getLogger(HttpServer.class);
	
	
	/**
	 * 初始化服  整行传输--new TextLineCodecFactory(Charset.forName( "UTF-8" ))
	 * @throws IOException
	 */
	public static void initialize() throws IOException {
	    // Create an Acceptor
	    NioSocketAcceptor acceptor = new NioSocketAcceptor();
	    // Add Handler
	    acceptor.setHandler(new HttpServerHandler());
	    //过滤器链
	    DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
	    //日志
	    LoggingFilter loggingFilter = new LoggingFilter();
        loggingFilter.setSessionClosedLogLevel(LogLevel.NONE);
        loggingFilter.setSessionCreatedLogLevel(LogLevel.DEBUG);
        loggingFilter.setSessionOpenedLogLevel(LogLevel.INFO);
        loggingFilter.setExceptionCaughtLogLevel(LogLevel.ERROR);
	    chain.addLast("logging", loggingFilter);
	    //黑名单
	    InetAddress[] addressArr = new InetAddress[]{};
	    BlacklistFilter blackList = new BlacklistFilter();
	    blackList.setBlacklist(addressArr);
	    chain.addLast("blackList", blackList);
	    //编码解码过滤 --http请求
	    chain.addLast("codec",new ProtocolCodecFilter(new HttpServerProtocolCodecFactory()));
//	    chain.addLast("http.ds",new HttpServerCodec());
//	    chain.addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName( "UTF-8" ))));
	    //线程池
	    chain.addLast("threadPool",new ExecutorFilter(Executors.newCachedThreadPool()));
	    //session配置
	    SocketSessionConfig cfg = acceptor.getSessionConfig();
	    cfg.setReuseAddress(true);//设置复用地址
	    cfg.setReadBufferSize(GlobalParam.READ_BUFFER_SIZE);//
	    cfg.setSendBufferSize(GlobalParam.SEND_BUFFER_SIZE);//
	    cfg.setReceiveBufferSize(GlobalParam.RECEIVE_BUFFER_SIZE);//
//	    cfg.setIdleTime(IdleStatus.BOTH_IDLE, 2);
	    
        logger.info("Starting Server.... and then Listening on:"+GlobalParam.HTTP_SERVER_PORT);
        //Bind地址
        acceptor.bind(new InetSocketAddress(GlobalParam.HTTP_SERVER_PORT));
        logger.info("Server listening on "+GlobalParam.HTTP_SERVER_PORT);
	}

	public static void main(String[] args) {
		try {
			initialize();
		} catch (IOException e) {
	        logger.error("start Server is throw Exception ",e);
		}
	}
}

服务端Handler（HttpServerHandler.java）:

package com.server;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.apache.log4j.Logger;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.example.tcp.perf.TcpServer;

import com.AbstractHandler;
import com.myProtocols.HttpRequestMessage;
import com.myProtocols.HttpResponseMessage;

/**
 * 
 * @author wangchao
 * @Version 1.0
 * @date 2015-9-30 上午9:39:03
 */
public class HttpServerHandler extends AbstractHandler{
	private static final Logger logger = Logger.getLogger(TcpServer.class);
	
	@Override
	public void exceptionCaught(IoSession session, Throwable e)
			throws Exception {
		logger.debug(e.getMessage(),e);
//		e.printStackTrace();
	}

	@Override
	public void messageReceived(IoSession session, Object msg) throws Exception {
		
		HttpRequestMessage reqM = (HttpRequestMessage)msg;
		System.out.println("context..."+reqM.getContext());
		System.out.println("user===="+reqM.getParameter("user"));
		System.out.println("pwd===="+reqM.getParameter("pwd"));
		System.out.println("age===="+reqM.getParameter("age"));
		String[] users = reqM.getParameters("user");
		System.out.println("user parameters===="+users.length+"----"+users[0]);
		HttpResponseMessage respM = new HttpResponseMessage();
		respM.setContentType("text/html; charset=UTF-8");
		respM.appendBody("wangc  response Test测试测试aaa");
		session.write(respM);
//		session.write("ffffffffffffffffffff");
		session.close(false);
	}

	@Override
	public void messageSent(IoSession arg0, Object arg1) throws Exception {
		// TODO Auto-generated method stub
		logger.info("messageSent..."+getCurrentDate());
	}

	@Override
	public void sessionClosed(IoSession arg0) throws Exception {
		// TODO Auto-generated method stub
		logger.info("sessionClosed..."+getCurrentDate());
	}

	@Override
	public void sessionCreated(IoSession arg0) throws Exception {
		// TODO Auto-generated method stub
//		System.out.println("sessionCreated...");
		logger.info("sessionCreated..."+getCurrentDate());
	}

	@Override
	public void sessionIdle(IoSession session, IdleStatus arg1) throws Exception {
		// TODO Auto-generated method stub
		session.write("idle--"+getCurrentDate());
//		logger.info("sessionIdle "+CommonsUtils.getCurrentDate());
	}

	@Override
	public void sessionOpened(IoSession arg0) throws Exception {
		// TODO Auto-generated method stub
		logger.info("sessionOpened..."+getCurrentDate());
	}
	
	private static String getCurrentDate(){
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
		return sdf.format(new Date());
	}
}