Missian指南四：使用同步客户端

同步客户端比较简单，它具备以下能力：

 

1、同步调用Missian服务（通过HTTP或TCP均可）

2、同步调用Hessian服务

3、使用短连接。作者本人的经验是，在网络通信时，使用短连接比较简单，在一个机柜或者机房内的通信，可以考虑短连接。

4、使用连接池，保持长连接。

 

我们先来看看Missian的同步客户端是怎么工作的。

 

步骤一：创建SyncMissianProxyFactory

默认构造函数：

Java代码


 




SyncMissianProxyFactory factory = new SyncMissianProxyFactory();   
          

SyncMissianProxyFactory factory = new SyncMissianProxyFactory();

这个构造函数使用短连接，并使用默认的网络参数来创建连接（默认参数见NetworkConfig类）。如果需要自己指定网络参数，那么：

Java代码


 




NetworkConfig config = new NetworkConfig();   
config.setConnectTimeout(20);   
SyncMissianProxyFactory factory = new SyncMissianProxyFactory(config);        

NetworkConfig config = new NetworkConfig();
config.setConnectTimeout(20);
SyncMissianProxyFactory factory = new SyncMissianProxyFactory(config);

如果希望使用长连接，必须指定一个连接池： 

Java代码


 




NetworkConfig config = new NetworkConfig();   
config.setConnectTimeout(20);   
SyncMissianProxyFactory factory = new SyncMissianProxyFactory(new CommonSocketPool(config));   
          

NetworkConfig config = new NetworkConfig();
config.setConnectTimeout(20);
SyncMissianProxyFactory factory = new SyncMissianProxyFactory(new CommonSocketPool(config));

注意构造函数接受的是一个叫做SocketPool的接口，Missian提供了一个基于apache commons-pool的实现CommonSocketPool，它有三个构造函数：

 

Java代码


 




public CommonSocketPool(){}   
public CommonSocketPool(NetworkConfig networkConfig){}   
public CommonSocketPool(NetworkConfig networkConfig, GenericKeyedObjectPool.Config config){}  

public CommonSocketPool(){}
public CommonSocketPool(NetworkConfig networkConfig){}
public CommonSocketPool(NetworkConfig networkConfig, GenericKeyedObjectPool.Config config){}

 第三个构造函数接受两个参数，一个用于指定网络参数，一个用于指定连接池参数；前面两个构造函数对没有传入的参数使用默认值。 

 

步骤二：创建Stub并调用Messian服务

这个和Hessian是完全一样的，熟悉Hessian的朋友应该感到很亲切：

 

Java代码


 




Hello hello = (Hello)factory.create(Hello.class, "tcp://localhost:1235/hello");   
System.out.println(hello.hello("hy", 27));   
   

Hello hello = (Hello)factory.create(Hello.class, "tcp://localhost:1235/hello");
System.out.println(hello.hello("hy", 27));

 

这是基于tcp来调用Missian服务，如果希望使用HTTP方式（比如有防火墙限制，只接受HTTP数据包的情况）：

Java代码


 




Hello hello = (Hello)factory.create(Hello.class, "http://localhost:1235/hello");   
System.out.println(hello.hello("hy", 27));   
   

Hello hello = (Hello)factory.create(Hello.class, "http://localhost:1235/hello");
System.out.println(hello.hello("hy", 27));

  

步骤三：试试调用Hessian服务

由于Missian完全兼容Hessian，这个同步客户端是可以调用Hessian的。我们这就创建一个Hessian服务试一试。

 

1、在Eclipse中创建一个动态Web项目，比如叫做hessianTest，把Hessian的发行包加入到WEB-INF/lib下

2、实现一个HessianServlet

Java代码


 




public class HServlet extends HessianServlet implements Hello{   
    private static final long serialVersionUID = 1L;   
          
    /**  
     * @see HessianServlet#HessianServlet()
 
     */  
    public HServlet() {   
        super();   
        // TODO Auto-generated constructor stub  
    }   
       
    public String hello(String name, int age) {   
        // TODO Auto-generated method stub  
        return name+":"+age;   
    }   
}  

public class HServlet extends HessianServlet implements Hello{
private static final long serialVersionUID = 1L;

/**
* @see HessianServlet#HessianServlet()
*/
public HServlet() {
super();
// TODO Auto-generated constructor stub
}

public String hello(String name, int age) {
// TODO Auto-generated method stub
return name+":"+age;
}
}

 

注意这里引用到了我们前面定义的Hello接口，所以需要把这个接口拷贝过来，或者通过项目引用使得这个Web项目能使用Hello接口。

3、在web.xml中配置这个Servlet：

Xml代码


 




<servlet>  
    <description></description>  
    <display-name>HServlet</display-name>  
    <servlet-name>HServlet</servlet-name>  
    <servlet-class>com.hessian.servlet.HServlet</servlet-class>  
  </servlet>  
  <servlet-mapping>  
    <servlet-name>HServlet</servlet-name>  
    <url-pattern>/hessian</url-pattern>  
  </servlet-mapping>  

<servlet>
<description></description>
<display-name>HServlet</display-name>
<servlet-name>HServlet</servlet-name>
<servlet-class>com.hessian.servlet.HServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>HServlet</servlet-name>
<url-pattern>/hessian</url-pattern>
</servlet-mapping>

4、启动这个Web引用

5、用Missian客户端去调用这个Hessian服务

Java代码


 




Hello hello = (Hello)factory.create(Hello.class, "http://localhost:8080/hessianTest/hessian");   
System.out.println(hello.hello("hy", 27));  

Hello hello = (Hello)factory.create(Hello.class, "http://localhost:8080/hessianTest/hessian");
System.out.println(hello.hello("hy", 27));

是的，一样也调用成功了。

 

作者认为，Missian客户端比之Hessian客户端，优势在于：

1、可以自由选择长短连接，可以配置各种网络参数

2、有一个完全用户可控的连接池 

 

Author: gh_aiyz

Forward:  http://missian.iteye.com/blog/830134