在Spring中配置RMI

使用RMI服务

创建RMI服务的基本步骤

1. 编写一个服务实现类，类中的方法必须抛出java.rmi.RemoteException异常
2. 创建一个继承于java.rmi.Remote的服务接口
3. 运行RMI编译器（rmic），创建额客户端的stub类和服务端的skeleton类
4. 启动一个RMI注册表，以便持有这些服务
5. 在RMI注册表中注册服务

Spring中的RPC

在Spring中配置RMI服务

服务端（com.yrls.*）

• IUserService.java

package com.yrls.service;

public interface IUserService {

    public String getStr(String abc);
}

• UserServiceImpl.java

package com.yrls.service.impl;

import com.yrls.service.IUserService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;

@Service("userService")
public class UserServiceImpl implements IUserService {

    @Override
    public String getStr(String abc){
        return abc;
    }
}

• spring-mvc

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:p="http://www.springframework.org/schema/p" xmlns:cache="http://www.springframework.org/schema/mvc"
       xmlns:c="http://www.springframework.org/schema/c"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context.xsd
       http://www.springframework.org/schema/mvc
       http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">

    <!-- 扫描web相关的bean -->
    <context:component-scan base-package="com.yrls.controller"/>

    <!-- 开启SpringMVC注解模式 -->
    <mvc:annotation-driven/>

    <!-- 静态资源默认servlet配置 -->
    <mvc:default-servlet-handler/>

    <!--开启AOP-->
    <aop:aspectj-autoproxy/>

    <bean id="serviceExporter" class="org.springframework.remoting.rmi.RmiServiceExporter">
        <!--暴露的服务名称-用于客户端获取-->
        <property name="serviceName" value="RpcUserService" />
        <!--暴露的服务-userService是来自@Bean注解UserServiceImpl.java得的Bean-->
        <property name="service" ref="userService" />
        <!--暴露的服务接口-->
        <property name="serviceInterface"
                  value="com.yrls.service.IUserService" />
        <property name="registryPort" value="8080" />
        <property name="servicePort" value="1099" />
    </bean>
    
    <!-- bean(userService)也可以在xml中配置 -->
    <!--
    <bean id="userService" class="com.yrls.service.impl.UserServiceImpl"/>
    -->
    
    <!--配置jsp 显示ViewResolver -->
    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>
        <property name="prefix" value="/WEB-INF/views/"/>
        <property name="suffix" value=".jsp"/>
    </bean>


</beans>

客户端（com.rpc.*）

• IUserService

package com.rpc.service;

public interface IUserService {

    public String getStr(String abc);
}

• Spring-mvc.xml

<bean id="mobileAccountService" class="org.springframework.remoting.rmi.RmiProxyFactoryBean">
    <!--8080端口对应服务端tomcat端口-->
    <!--localhost对应服务端的ip-->
    <!--RpcUserService暴露的服务名称-->
    <property name="serviceUrl" value="rmi://localhost:8080/RpcUserService" />
    <!-- 接口为client包里的接口，跟服务端的一致-->
    <!-- 接口的实现调用服务端暴露的远程服务-->
    <property name="serviceInterface"
              value="com.rpc.service.IUserService" />
</bean>

• UserController.java

package com.rpc.controller;

import com.rpc.service.IUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Component
@Controller
@RequestMapping("/rpc")
public class UserController {

    @Autowired
    private IUserService service;

    @ResponseBody
    @RequestMapping("cc")
    public String cc(){
        String a = service.getStr2("Hello RMI!!!");
        return a;
    }
}