# spring-rmi-client

**Repository Path**: judeli/spring-rmi-client

## Basic Information

- **Project Name**: spring-rmi-client
- **Description**: rmi的集群化客户端，类似dubbo的客户端，基于cluster4spring扩展，支持spring。非常适合使用了rmi rpc的老项目，轻松获得rmi调用的客户端负载均衡能力
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2019-03-22
- **Last Updated**: 2024-02-04

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

#使用案例

1、client配置
   <!-- 一对多 静态  客户端配置-->
    <bean id="rmiClientSetting" abstract="true">
        <!-- 是否启动时加载stub -->
        <property name="refreshEndpointsOnStartup" value="false" />
        <!-- 调用异常时，将重新加载stub -->
        <property name="refreshEndpointsOnConnectFailure" value="true" />
        <!-- 调用失败时是否切换到其他服务端 -->
        <property name="switchEndpointOnFailure" value="true" />
        <!-- 追踪拦截器启用 -->
        <property name="registerTraceInterceptor" value="true" />
        <!-- 缓存stub 继承AbstractRmiShortFormProxyFactoryBean才有-->
        <property name="cacheEndpoints" value="true" />
    </bean>
    
    <bean id="rmiClientSetting4Zoo" abstract="true" parent="rmiClientSetting">
        <property name="zkClient" ref="zkClient"/>
    </bean>
    
    <bean id="callHistoryCrmRmiService" class="org.softamis.cluster4spring.rmi.ZookeeperRmiDiscoveringProxyFactoryBean" parent="rmiClientSetting4Zoo">
        <property name="rmiServerProjectName" value="hfzyCache"/>
        <property name="serviceName" value="callHistoryCrmRmiService"/>
        <property name="serviceInterface" value="com.ihk.bd.rmi.client.CallHistoryCrmRmiService" />
    </bean>
    
    <bean id="zkClient" class="org.softamis.cluster4spring.rmi.ZookeeperFactoryBean">
        <property name="zkHosts" value="172.16.8.87:2181"/>
        <property name="zkSessionTimeOut" value="15000"/>
        <property name="zkConnectionTimeout" value="5000"/>
    </bean>


2、server配置

    <!-- RMI调用拦截器 控制调用权限，白名单 -->
    <bean id="rmiSecurityInterceptor" class="com.hfzy.ihk.cloud.common.rmi.RmiSecurityInterceptor">
        <!-- 这里配置允许访问rmi的客户端IP地址 ,空时允许所有IP访问-->
        <property name="allowed">
            <set>
                <!--
                <value>172.16.xxx.xxx</value>
                -->
            </set>
        </property>
    </bean>
    
    <bean id="rmiServerPropertySetting" abstract="true">
        <property name="interceptors">
            <list>
                <ref bean="rmiSecurityInterceptor"/>
            </list>
        </property>
        <property name="registryPort" value="60000"/><!-- 默认1099 -->
        <property name="servicePort" value="60000"/><!--tcp通信端口，不指定就随机 -->
    </bean>
    
    <bean id="callHistoryCrmRmiService" class="com.ihk.bd.linkcall.rmi.service.impl.CallHistoryCrmRmiServiceImpl"/>
    
    <bean id="callHistoryCrmRmiServiceExporter" class="org.springframework.remoting.rmi.RmiServiceExporter" parent="rmiServerPropertySetting">
        <!--指定一个服务名，唯一就好。(后续改进，将自动设置）-->
        <property name="serviceName" value="callHistoryCrmRmiService"/>
        <!--注入提供服务的bean-->
        <property name="service" ref="callHistoryCrmRmiService" />
        <!--指定提供的bean实现的接口。(后续改进，将自动设置）-->
        <property name="serviceInterface"  value="com.hfzy.ihk.cloud.facade.callCenter.service.CallHistoryCrmRmiService" />
    </bean>
    
    <!--注册到zookeeper-->
    <bean class="org.softamis.cluster4spring.rmi.ZookeeperSpringRmiPublisher">
        <property name="zkClient" ref="zkClient" />
        <!--相当于服务分组-->
        <property name="rmiServerProjectName" value="cloudcall"/>
        <property name="rmiServiceExporters">
            <set>
                <ref bean="callHistoryCrmRmiServiceExporter"/>
            </set>
        </property>
    </bean>
    
    <bean class="org.softamis.cluster4spring.rmi.ZookeeperSpringRmiPublisher" >
        <property name="zkClient" ref="zkClient" />
        <!--相当于服务分组,这里是外网-->
        <property name="rmiServerProjectName" value="outCloudcall"/>
        <!--端口映射,注意JVM必须配置-Djava.rmi.server.hostname参数-->
        <property name="portMappings">
            <map>
                <entry key="10.10.xxx.xxx:60000" value="113.108.xxx.xxx:60000"/>
            </map>
        </property>
        <property name="rmiServiceExporters">
            <set>
                <ref bean="callHistoryCrmRmiServiceExporter"/>
            </set>
        </property>
    </bean>