安全性包括身份验证和数据传输安全两个方面，身份验证可以根据调用双方的信任程度以及性能要求确定采用对称加密或者非对称加密，当前提供了三种验证措施，用户名加密认证，IP认证，以及消息数字摘要加密验证，该验证可以在Spring Remoting基础上进行扩展。数据传输安全则主要是担心数据在传输过程中被截获，对于基于Http的传输，使用Https即可(无需在框架或者应用层支持)。

调用频度控制，则可以应用AOP技术，对于调用进行截获和统计，根据一定的规则，判断调用是否符合控制策略。

接口定义和实现规范

接口定义和实现为简单的POJI和POJO即可，不过为了满足远程调用的需要，需要保证所有参数和返回值都是可序列化的，另外，鉴于部分远程调用技术的序列化机制的特殊性(例如Hessian)，数据类型应尽可能简单。此外，基于性能考虑，远程接口调用方式适用于中低频度的小数据量的调用，对于大批量数据同步或者相当高频度的调用，远程接口调用方式并不合适。

设计实现

基本类图

图1 远程服务发布类结构图

针对Hessian和HttpInvoker两种远程服务调用的方式封装了对于安全控制的两个安全发布类，具体的安全配置以及安全操作都在RemoteContractTemplate中，这样可以方便扩展任何安全的需求变更，并且对原有任何的Exporter做了安全切面处理，防止过度耦合。

图 2 远程服务调用类结构图

远程服务调用对于不同的方法调用需要不同的定制，这里针对Hessian和HttpInvoker采用了替换植入内部处理类的方式，Hessian植入了新的HessianProxyFactory用来生成新的HessianProxy来植入安全机制，HttpInvokerFactoryBean植入了新的HttpInvokerRequestExecutor来植入安全机制，同样安全配置以及操作都封装在RemoteContractTemplate中，集中控制和配置，方便扩展和管理。

基本流程图

图 3 基本流程图

如上图所示，用户发起请求调用远程服务，首先是创建远程服务代理，然后通过植入安全信息将请求发送到远程服务发布处理类中，首先检查安全信息，如果通过安全检测就进入方法调用拦截器中检验类似于频率之类的限制过程中，通过拦截器的检测就可以调用真正的远程服务，并且获得结果，将结果返回并封装安全信息返回给服务调用代理，代理首先检测是否有合法的安全信息，如果通过安全信息认证，将结果返回给客户端。

具体的配置和使用

这里通过一个Demo来说明如何使用这个远程服务调用框架。

假定一个售票管理服务要发布，售票管理服务结构图如下：

图 4 售票管理服务结构图

服务类接口为TicketManage，实现类是TicketManageImpl。测试调用类为TicketManageClient。接口和接口的实现类就是按照普通的Java规范来实现即可，TicketManageClient根据你选择不同的服务调用方式来编写代码，这里用到了Hessian和HttpInvoker两种方式，代码如下：

public static void main(String[] args)

{

ApplicationContext ctx = new ClassPathXmlApplicationContext("ticket.xml");

TicketManage ticketManage = (TicketManage)ctx.getBean("ticketService");//hession调用的配置

Ticket ticket = ticketManage.buyTicket(20);

System.out.println("ticket seat: " + ticket.getSeat());

int returncost = ticketManage.returnTicket(ticket);

System.out.println("return ticket, get back cost :" + returncost);

TicketManage httpTicketManage = (TicketManage)ctx.getBean("ticketHttpService");//HttpInvoke调用的配置

ticket = httpTicketManage.buyTicket(30);

System.out.println("ticket seat: " + ticket.getSeat());

returncost = httpTicketManage.returnTicket(ticket);

System.out.println("return ticket, get back cost :" + returncost);

}

ticket.xml是客户端的spring配置文件，具体的内容如下：

<?xml version="1.0" encoding="GB2312"?>

<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">

<!—- 安全模版配置类，参数在后面会有详细解释 -->

<list>

<value>taobao</value>

<value>zhifubao</value>

</list>

</property>

<list>

</list>

</property>

</bean>

<!—- 需要植入到HttpInvokerProxyFactoryBean的安全请求处理类 -->

</bean>

<!—- 发布服务的Bean -->

</bean>

<!—- Hessian的安全代理工厂类Bean -->

</bean>

</bean>

</beans>

上面的xml中蓝色的内容需要根据具体的情况作修改，黑色的内容则不需要修改。

安全模版配置类参数具体说明：下面是代码中的说明，大家一看就应该明白了

private String encryptKeyPath;//encryptKey的路径

private String decryptKeyPath;//decryptKey的路径

private Key encryptKey;//根据encryptKey的路径生成的key

private Key decryptKey;//根据decryptKey的路径生成的key

private String algonrithm;//算法

private String needMD;//是否需要MD校验

private String needUserAuth;//是否需要加密

private List<String> user;//允许对方访问或者返回结果的用户名

private String owner;//自己的签名

private byte[] encrypted;//加密后的用户签名，一次加密，多次使用，增加性能提升

private String encoding = "GB2312";//编码方式，加密和md的内容的编码方式

private String needIPAuth;//是否需要IP认证

private List<String> ipList;//允许访问的ip列表

private int readTimeout = 0;// 读取数据超时时间设置，单位秒

private int connectTimeout = 0;// 连接超时时间设置，单位秒

客户端设置好以后，就需要设置服务端了：

服务端很简单首先是类似于Spring的Hessian和HttpInvoker调用的配置一样，在WEB-INF/lib下面放入toolkit-sandbox-remoting.jar以及其它以来的jar，然后配置web.xml，增加如下内容（这都是spring mvc框架的配置，大家可以参考spring来配置）：

<servlet-name>remote</servlet-name>

<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

<load-on-startup>1</load-on-startup>

</servlet>

<servlet-mapping>

<servlet-name>remote</servlet-name>

<url-pattern>/remote/*</url-pattern>

</servlet-mapping>

然后在WEB-INF下面新建remote-servlet.xml，如果要换名称，需要在上面的配置文件配置。

remote-servlet.xml内容如下：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:sca="http://www.springframework.org/schema/sca"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:osgi="http://www.springframework.org/schema/osgi"

xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/sca http://www.springframework.org/schema/sca/spring-sca.xsd http://www.springframework.org/schema/osgi http://www.springframework.org/schema/osgi/spring-osgi.xsd" default-autowire="byName">

<!—- 拦截器bean -->

<list>

<value>remoteMethodInterceptor</value>

</list>

</property>

</bean>

<!—- 上面的配置代表了每小时不能超过20次的访问 -->

</bean>

<list>

<value>alisoft</value>

<value>zhifubao</value>

</list>

</property>

</bean>

<!—- HttpService发布Bean,植入了安全策略配置模版 -->

</bean>

<!—- Hessian服务发布Bean,植入了安全策略配置模版 -->

</bean>

</beans>

最后需要做的就是生成key，当前key的算法有两种，对称加密和非对称加密，分别用AES算法和RSA算法，注意一旦产生了Key文件，双方就要使用相同的key文件，同一个用户加解密的key文件可以不一致，但是双方的解密和加密文件必须配对使用。

产生key文件的方法如下：

将toolkit-sandbox-remoting.jar所在的位置配置到classpath中，然后通过命令行执行。

生成对称加密key文件命令为：

Java com.alibaba.common.remoting.cryption.KeyGenTool genkey 文件目录文件名

生成非对称加密key文件命令为：

Java com.alibaba.common.remoting.cryption.KeyGenTool genkeypair 文件目录文件名

这样你分别会在文件目录中找到对应得文件，后缀名为.ky

分享到：

Log4j配置参数详解　 | 大型Java分布式应用

2012-07-18 17:24
浏览 3126
评论(0)
分类:企业架构
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

远程服务调用框架设计与实现

目的

实现技术

接口定义和实现规范

设计实现

基本类图

基本流程图

具体的配置和使用

评论

发表评论

相关推荐

最近访客 更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

远程服务调用框架设计与实现

目的

实现技术

接口定义和实现规范

设计实现

基本类图

基本流程图

具体的配置和使用

评论

发表评论

相关推荐

Gossip 协议--分布式系统状态同步协议 - [分布式算法]

Thrift入门及Java实例演示

大型Java分布式应用

JGroup 使用分享

最近访客更多访客>>