Missian指南三：创建一个Missian服务器（使用spring）

在使用Missian时，spring是可选的，但是作者本人强烈推荐和Spring配合使用。Spring是一个伟大的项目，并且它不会对程序在运行时的效率带来任何损耗。

Missian在服务器端依赖与Mina，Missian只是提供一个Codec（协议编码解码，兼容TCP和HTTP）和一个Handler（调用Hessian序列化机制来反序列化数据、使用BeanLocator来定位这次调用的Bean）。熟悉Mina的朋友会很清楚Codec和Handler的概念；不熟悉的朋友也没关系，按照这个教程一样可以创建一个高效的服务来。对Mina没有兴趣的朋友可以直接跳到第七步：）

步骤一：创建一个spring配置文件。

Xml代码  

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
  5. </beans>

步骤二：配置文件中加入：

Xml代码  

  1. <bean class="org.springframework.beans.factory.config.CustomEditorConfigurer">
  2. <property name="customEditors">
  3. <map>
  4. <entry key="java.net.SocketAddress">
  5. <bean class="org.apache.mina.integration.beans.InetSocketAddressEditor" />
  6. </entry>
  7. </map>
  8. </property>
  9. </bean>

这个是最后绑定端口时，用来将10.1.23.1:125转换成SocketAddress的，不用太关注。

步骤三：配置各个Mina的Filter

注意ExecutorFitler是使用的默认构造函数，要指定线程数，或者将已有的线程池传入，可以使用其它的构造函数；LoggingFilter中除了Exception之外的时间的Log级别已经全部设为DEBUG；CodecFilter是关键，这里引入了Missian的编码解码器。

Java代码  

  1. <bean id="executorFilter" class="org.apache.mina.filter.executor.ExecutorFilter" />
  2. <bean id="codecFilter" class="org.apache.mina.filter.codec.ProtocolCodecFilter">
  3. <constructor-arg>
  4. <bean class="com.missian.server.codec.MissianCodecFactory" />
  5. </constructor-arg>
  6. </bean>
  7. <bean id="loggingFilter" class="org.apache.mina.filter.logging.LoggingFilter">
  8. <property name="messageReceivedLogLevel" value="DEBUG"/>
  9. <property name="messageSentLogLevel" value="DEBUG"/>
  10. <property name="sessionCreatedLogLevel" value="DEBUG"/>
  11. <property name="sessionClosedLogLevel" value="DEBUG"/>
  12. <property name="sessionIdleLogLevel" value="DEBUG"/>
  13. <property name="sessionOpenedLogLevel" value="DEBUG"/>
  14. </bean>

步骤四：构建FilterChian

这里我把Codec放在线程池之前，因为编码解码是CPU密集型的操作，使用线程池并不能提高效率。当然了，有兴趣的朋友可以自己调整顺序做一下测试。

Java代码  

  1. <bean id="filterChainBuilder"
  2. class="org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder">
  3. <property name="filters">
  4. <map>
  5. <entry key="codecFilter" value-ref="codecFilter" />
  6. <entry key="executor" value-ref="executorFilter" />
  7. <entry key="loggingFilter" value-ref="loggingFilter" />
  8. </map>
  9. </property>
  10. </bean>

步骤五：创建IoHandler。

这一步也很重要，引入了Missian的处理器，就是在这里调用了Hessian的序列化机制，并完成对相应的Bean的调用。

Xml代码  

  1. <bean id="minaHandler" class="com.missian.server.handler.MissianHandler">
  2. <constructor-arg>
  3. <bean class="com.missian.common.beanlocate.SpringLocator" />
  4. </constructor-arg>
  5. </bean>

MissianHandler接受一个BeanLocator的构造菜熟，注意这里直接给MissianHandler注入了一个SpringLocator，使得Missian有能力去Spring去寻找相应的Bean。

这里是一个很好的扩展点，有需要的话可以在BeanLocator上做做文章。

步骤六：创建一个Acceptor，监听端口

Java代码  

  1. <bean id="minaAcceptor" class="org.apache.mina.transport.socket.nio.NioSocketAcceptor"
  2. init-method="bind" destroy-method="unbind">
  3. <property name="defaultLocalAddress" value=":1235" />
  4. <property name="handler" ref="minaHandler" />
  5. <property name="reuseAddress" value="true" />
  6. <property name="filterChainBuilder" ref="filterChainBuilder" />
  7. </bean>

到此位置，missian服务配置完毕。接下来配置一下业务逻辑的Bean。

步骤七：配置一个业务逻辑Bean，供Missian客户端调用

Java代码  

  1. <bean id="hello" class="com.missian.example.bean.HelloImpl"></bean>

上一篇指南里面创建的这个类第一次出境了，鼓掌……

注意bean的id叫做‘hello’，missian客户端就是通过‘hello’这个名称找到这个bean的，例如:http://www.abc.cn/hello。

值得一提的是如果客户端想通过http://www.abc.cn/p/hello来访问这个bean，那么这个bean的配置应该如此：

Java代码  

  1. <bean name="p/hello" class="com.missian.example.bean.HelloImpl"></bean>

ID属性是不能出现斜杠的，所以通过name来定义这个bean。

步骤八：启动服务器

Java代码  

  1. public class ServerWithSpring {
  2. /**
  3. * @param args
  4. */
  5. public static void main(String[] args) {
  6. new ClassPathXmlApplicationContext("com/missian/example/server/withspring/applicationContext-*.xml");
  7. }
  8. }

运行ServerWithSpring即启动了整个服务了。服务将监听1235端口，接受HTTP协议和TCP协议格式的请求。

步骤九：用Hessian来调用此服务

由于Missian服务器是兼容Hessian的，所以，在创建Missian客户端之前，让我们用Hessian客户端来测试一下这个服务吧。

Java代码  

  1. HessianProxyFactory factory = new HessianProxyFactory();
  2. Hello hello = (Hello) factory.create(Hello.class, "http://localhost:1235/hello");
  3. System.out.println(hello.hello("test", 27));

是的，你会发现调用成功了。

完整的配置文件如下 ：

Java代码  

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
  5. <bean class="org.springframework.beans.factory.config.CustomEditorConfigurer">
  6. <property name="customEditors">
  7. <map>
  8. <entry key="java.net.SocketAddress">
  9. <bean class="org.apache.mina.integration.beans.InetSocketAddressEditor" />
  10. </entry>
  11. </map>
  12. </property>
  13. </bean>
  14. <!-- The IoHandler implementation -->
  15. <bean id="minaHandler" class="com.missian.server.handler.MissianHandler">
  16. <constructor-arg>
  17. <bean class="com.missian.common.beanlocate.SpringLocator" />
  18. </constructor-arg>
  19. </bean>
  20. <!-- the IoFilters -->
  21. <bean id="executorFilter" class="org.apache.mina.filter.executor.ExecutorFilter" />
  22. <bean id="codecFilter" class="org.apache.mina.filter.codec.ProtocolCodecFilter">
  23. <constructor-arg>
  24. <bean class="com.missian.server.codec.MissianCodecFactory" />
  25. </constructor-arg>
  26. </bean>
  27. <bean id="loggingFilter" class="org.apache.mina.filter.logging.LoggingFilter">
  28. <property name="messageReceivedLogLevel" value="DEBUG"/>
  29. <property name="messageSentLogLevel" value="DEBUG"/>
  30. <property name="sessionCreatedLogLevel" value="DEBUG"/>
  31. <property name="sessionClosedLogLevel" value="DEBUG"/>
  32. <property name="sessionIdleLogLevel" value="DEBUG"/>
  33. <property name="sessionOpenedLogLevel" value="DEBUG"/>
  34. </bean>
  35. <!-- The non-SSL filter chain. -->
  36. <bean id="filterChainBuilder"
  37. class="org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder">
  38. <property name="filters">
  39. <map>
  40. <entry key="codecFilter" value-ref="codecFilter" />
  41. <entry key="executor" value-ref="executorFilter" />
  42. <entry key="loggingFilter" value-ref="loggingFilter" />
  43. </map>
  44. </property>
  45. </bean>
  46. <!-- The IoAcceptor which binds to port 1235 server side -->
  47. <bean id="minaAcceptor" class="org.apache.mina.transport.socket.nio.NioSocketAcceptor"
  48. init-method="bind" destroy-method="unbind">
  49. <property name="defaultLocalAddress" value=":1235" />
  50. <property name="handler" ref="minaHandler" />
  51. <property name="reuseAddress" value="true" />
  52. <property name="filterChainBuilder" ref="filterChainBuilder" />
  53. </bean>
  54. <!-- your business bean, missian client will call this bean by ‘hello‘ -->
  55. <bean id="hello" class="com.missian.example.bean.HelloImpl"></bean>
  56. </beans>
时间： 2024-10-09 23:59:40

Missian指南三：创建一个Missian服务器（使用spring）的相关文章

python网络编程之 创建一个socketserverTCP服务器

#encoding=utf-8#创建一个socketserverTCP服务器#高级模块,简化客户和服务器的实现from SocketServer import (TCPServer as TCP,StreamRequestHandler as SRH)from time import ctime host = ''port = 21567addr = (host,port) #从 SocketServer 的 StreamRequestHandler 类中派生出一个子类class MyReque

创建一个简单服务器用到的基本函数

一,socket()头文件:#include <sys/socket.h>函数原型:int socket(int domain, int type, int protocol);作用:创建套接字. 参数domain:指定使用何种的地址类型.默认AF_INET.eg: AF_INET IPv4网络通信AF_INET6 IPv6网络通信AF_PACKET 链路层通信AF_UNIX, AF_LOCAL 本地通信 参数type:套接字类型.默认SOCK_STREAM.eg:1.SOCK_STREAM

Git简易指南三--创建版本库

什么是版本库呢?版本库又名仓库,英文名repository,你可以简单理解成一个目录,这个目录里面的所有文件都可以被Git管理起来,每个文件的修改.删除,Git都能跟踪,以便任何时刻都可以追踪历史,或者在将来某个时刻可以“还原”. 所以,创建一个版本库非常简单,首先,选择一个合适的地方,创建一个空目录: $ mkdir learngit $ cd learngit $ pwd /home/exbot/learngit //登陆用户是exbot 这个仓库位于/home/exbot/learngit

新建一个tomcat服务器，spring+jersey完成上传图片的实现

万年不变开头,添加依赖 <!-- https://mvnrepository.com/artifact/com.sun.jersey/jersey-client --> <dependency> <groupId>com.sun.jersey</groupId> <artifactId>jersey-client</artifactId> <version>1.19.4</version> </depen

python web编程 创建一个web服务器

这里就介绍几个底层的用于创建web服务器的模块,其中最为主要的就是BaseHTTPServer,很多框架和web服务器就是在他们的基础上创建的 基础知识 要建立一个Web 服务,一个基本的服务器和一个“处理器”是必备的. 基础的(Web)服务器是一个必备的模具.它的角色是在客户端和服务器端完成必要HTTP 交互.在BaseHTTPServer 模块中你可以找到一个名叫HTTPServer 的服务器基本类. 处理器是一些处理主要“Web 服务”的简单软件.它们处理客户端的请求,并返回适当的文件,静

Docker 使用入门，创建一个Nginx服务器

运行环境: MAC Docker 版本: Docker version 17.12.0-ce, build c97c6d6 一.启动Nginx 服务器 启动Nginx 服务器,并进入模拟终端 docker run -p 8080:80 --name nginx_web -it nginx /bin/bash 二.了解Nginx 镜像的配置文件位置 日志文件位置:/var/log/nginx 配置文件位置: /etc/nginx 资源存放的位置: /usr/share/nginx/html 上面的

【spring教程之一】创建一个最简单的spring例子

1.首先spring的主要思想,就是依赖注入.简单来说,就是不需要手动new对象,而这些对象由spring容器统一进行管理. 2.例子结构 如上图所示,采用的是maven工程. 2.pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="htt

【spring教程之中的一个】创建一个最简单的spring样例

1.首先spring的主要思想,就是依赖注入.简单来说.就是不须要手动new对象,而这些对象由spring容器统一进行管理. 2.样例结构 如上图所看到的,採用的是mavenproject. 2.pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation=&q

搭建QQ聊天通信的程序：（1）基于 networkcomms.net 创建一个WPF聊天客户端服务器应用程序 （1）

搭建QQ聊天通信的程序:(1)基于 networkcomms.net 创建一个WPF聊天客户端服务器应用程序 原文地址(英文):http://www.networkcomms.net/creating-a-wpf-chat-client-server-application/ 注意:本教程是相当广泛的,如果你是在短请也看到我们的东西 开始和 如何在几分钟内创建一个客户端服务器应用程序教程. 注2:本例中包括,明显延长进一步证明功能,在包中包含的示例 包下载. 在我们开始之前确保您已经安装了Vis