黑马程序员技术交流社区

标题: 使用Apache MINA框架搭建服务端 [打印本页]

---

作者: yangcy    时间: 2014-7-10 13:11
标题: 使用Apache MINA框架搭建服务端


使用MINA框架搭建服务端步骤：
1、定义一个启动服务的类MinaServer，并实现接口ServletContextListener
2、定义一个处理业务逻辑的类MinaServerHandler，并继承类IoHandlerAdapter
类MinaServer代码如下：

1. import java.net.InetSocketAddress;
   
2. 
   
3. import javax.servlet.ServletContextEvent;
   
4. import javax.servlet.ServletContextListener;
   
5. import javax.servlet.http.HttpSessionEvent;
   
6. import javax.servlet.http.HttpSessionListener;
   
7. 
   
8. import org.apache.mina.core.session.IdleStatus;
   
9. import org.apache.mina.filter.codec.ProtocolCodecFilter;
   
10. import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
    
11. import org.apache.mina.filter.executor.ExecutorFilter;
    
12. import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
    
13. 
    
14. import com.utils.LogUtil;
    
15. 
    
16. public class MinaServer implements ServletContextListener, HttpSessionListener {
    
17.         private static NioSocketAcceptor acceptor;
    
18.         private static final int port = 9999;
    
19.         private static final LogUtil logUtil = LogUtil.getLogUtil(MinaServer.class);
    
20. 
    
21. 
    
22.         // 停止MINA服务
    
23.         public void contextDestroyed(ServletContextEvent sce) {
    
24.                 try {
    
25.                         MinaServer.acceptor.unbind();
    
26.                         MinaServer.acceptor.dispose();
    
27.                         logUtil.customLog("Mina服务停止...");
    
28.                 } catch (Exception e) {
    
29.                         logUtil.customLog(e);
    
30.                 }
    
31.         }
    
32. 
    
33.         // 启动MINA服务
    
34.         public void contextInitialized(ServletContextEvent sce) {
    
35.                 try {
    
36.                         // 创建一个非阻塞的server端的Socket
    
37.                         acceptor = new NioSocketAcceptor();
    
38.                         // 设置过滤器
    
39.                         acceptor.getFilterChain().addLast(
    
40.                                         "serverCodec",
    
41.                                         new ProtocolCodecFilter(
    
42.                                                         new ObjectSerializationCodecFactory()));
    
43.                         acceptor.getFilterChain().addLast("ServerFilter",
    
44.                                         new ExecutorFilter());
    
45.                         // 设置读取数据的缓冲区大小
    
46.                         acceptor.getSessionConfig().setReadBufferSize(1024*102400);
    
47.                         // 读写通道10秒内无操作进入空闲状态
    
48.                         acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
    
49.                         // 添加逻辑处理器
    
50.                         acceptor.setHandler(new MinaServerHandler());
    
51.                         // 绑定端口
    
52.                         try {
    
53.                                 acceptor.bind(new InetSocketAddress(port));
    
54.                         } catch (Exception e) {
    
55.                         }
    
56.                         logUtil.customLog("服务端启动成功...     端口号为：" + port);
    
57.                 } catch (Exception e) {
    
58.                         logUtil.customLog("服务端启动异常....");
    
59.                 }
    
60. 
    
61.         }
    
62. 
    
63.         public void sessionCreated(HttpSessionEvent arg0) {
    
64.         }
    
65. 
    
66.         public void sessionDestroyed(HttpSessionEvent arg0) {
    
67.         }
    
68. 
    
69. }

复制代码

类MinaServerHandler代码如下：

1. import org.apache.mina.core.service.IoHandlerAdapter;
   
2. import org.apache.mina.core.session.IdleStatus;
   
3. import org.apache.mina.core.session.IoSession;
   
4. 
   
5. import com.model.DeliverObject;
   
6. import com.model.Orders;
   
7. import com.model.Users;
   
8. import com.service.GoodsService;
   
9. import com.service.OrdersService;
   
10. import com.service.UserService;
    
11. import com.utils.GetBeanUtil;
    
12. import com.utils.LogUtil;
    
13. import com.utils.Params;
    
14. 
    
15. public class MinaServerHandler extends IoHandlerAdapter {
    
16. 
    
17.         private static final LogUtil logUtil = LogUtil
    
18.                         .getLogUtil(MinaServerHandler.class);
    
19. 
    
20.         @Override
    
21.         public void sessionCreated(IoSession session) throws Exception {
    
22.                 logUtil.customLog("服务端与客户端创建连接...");
    
23.         }
    
24. 
    
25.         @Override
    
26.         public void sessionOpened(IoSession session) throws Exception {
    
27.                 logUtil.customLog("服务端与客户端连接打开...");
    
28.         }
    
29. 
    
30.         @Override
    
31.         public void messageReceived(IoSession session, Object message)
    
32.                         throws Exception {
    
33. 
    
34.                 DeliverObject recvObj = (DeliverObject) message;
    
35.                 int optionType = recvObj.getOptionType();
    
36.                 // 如果是登录操作
    
37.                 if (optionType == Params.LOGIN) {
    
38.                         UserService userService = (UserService) GetBeanUtil
    
39.                                         .getBean("userService");
    
40.                         userService.doLogin(session, (Users) recvObj.getObj());
    
41.                 } else if (optionType == Params.REGISTER) {
    
42.                         // 如果是注册操作
    
43.                         UserService userService = (UserService) GetBeanUtil
    
44.                                         .getBean("userService");
    
45.                         userService.doRegister(session, (Users) recvObj.getObj());
    
46.                 } else if (optionType == Params.UPDATEUSER) {
    
47.                         // 如果是修改用户信息操作
    
48.                         UserService userService = (UserService) GetBeanUtil
    
49.                                         .getBean("userService");
    
50.                         userService.doUpdateUser(session, (Users) recvObj.getObj());
    
51.                 } else if (optionType == Params.SEARCHGOODS) {
    
52.                         // 如果是搜索商品操作
    
53.                         GoodsService goodsService = (GoodsService) GetBeanUtil
    
54.                                         .getBean("goodsService");
    
55.                         goodsService.doSearchGoods(session, (String) recvObj.getObj());
    
56.                 } else if (optionType == Params.SUBMITORDERS) {
    
57.                         // 如果是提交订单操作
    
58.                         OrdersService ordersService = (OrdersService) GetBeanUtil
    
59.                                         .getBean("ordersService");
    
60.                         ordersService.doSubmitOrders(session, (Orders) recvObj.getObj());
    
61.                 } else if (optionType == Params.SEARCHALLORDERS) {
    
62.                         // 如果是查询所有订单操作
    
63.                         OrdersService ordersService = (OrdersService) GetBeanUtil
    
64.                                         .getBean("ordersService");
    
65.                         ordersService.doSearchAllOrders(session, (Users) recvObj.getObj());
    
66.                 }
    
67. 
    
68.         }
    
69. 
    
70.         @Override
    
71.         public void messageSent(IoSession session, Object message) throws Exception {
    
72.                 logUtil.customLog("服务端发送信息成功...");
    
73.         }
    
74. 
    
75.         @Override
    
76.         public void sessionClosed(IoSession session) throws Exception {
    
77.                 logUtil.customLog("服务端与客户端连接关闭...");
    
78.                 session.close(true);
    
79.         }
    
80. 
    
81.         @Override
    
82.         public void sessionIdle(IoSession session, IdleStatus status)
    
83.                         throws Exception {
    
84.                 super.sessionIdle(session, status);
    
85.                 logUtil.customLog("服务端进入空闲状态...");
    
86.         }
    
87. 
    
88.         @Override
    
89.         public void exceptionCaught(IoSession session, Throwable cause)
    
90.                         throws Exception {
    
91.                 logUtil.customLog("服务端发送异常..." + cause);
    
92.                 session.close(true);
    
93.         }
    
94. 
    
95. }

复制代码

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2