首页 > 其他分享 >Spring与RMI集成实现远程访问

Spring与RMI集成实现远程访问

时间:2023-11-09 11:36:54浏览次数:30  
标签:集成 rmi 服务 Spring org RMI public 服务端 客户端


暴露你的服务;在客户端,通过org.springframework.remoting.rmi.RmiProxyFactoryBean可以使用服务端暴露的服务,非常方便。这种C/S模型的访问方式,可以屏蔽掉RMI本身的复杂性,如服务端Skeleton和客户端Stub等的处理细节,这些对于服务开发和服务使用的人员来说,都是透明的,无需过度关注,而集中精力开发你的商业逻辑。

下面通过一个例子,说明如何通过Spring集成RMI。

服务端发布服务

我们定义了服务接口,服务端实现该服务接口来完成其复杂的逻辑,客户端可以通过该接口调用服务端暴露的服务,如下所示:


package org.shirdrn.spring.remote.rmi;  
  
public interface AccountService {  
int queryBalance(String mobileNo);  
byte protocol);  
}


服务实现,示例如下所示:



package org.shirdrn.spring.remote.rmi;  
  
import org.apache.log4j.Logger;  
  
public class MobileAccountServiceImpl implements AccountService {  
  
private static final Logger LOG = Logger.getLogger(MobileAccountServiceImpl.class);  
public int queryBalance(String mobileNo) {  
if (mobileNo != null)  
return 100;  
return 0;  
    }  
  
public String shoopingPayment(String mobileNo, byte protocol) {  
new StringBuffer().append("Your mobile number is /"").append(  
"/", protocol type is /"").append(protocol)  
"/".");  
"Message is: " + sb.toString());  
return sb.toString();  
    }  
}


服务端发布服务,供客户端进行(远程方法)调用,Spring配置server.xml如下所示:


<?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:p="http://www.springframework.org/schema/p"  
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">  
  
<bean id="serviceExporter" class="org.springframework.remoting.rmi.RmiServiceExporter">  
<property name="serviceName" value="MobileAccountService" />  
<property name="service" ref="accountService" />  
<property name="serviceInterface"  
value="org.shirdrn.spring.remote.rmi.AccountService" />  
<property name="registryPort" value="8080" />  
<property name="servicePort" value="8088" />  
</bean>  
  
<bean id="accountService" class="org.shirdrn.spring.remote.rmi.MobileAccountServiceImpl" />  
  
</beans>


上面配置,指定了暴露的服务的名称,通过serviceName属性注入到RmiServiceExporter中,服务名称为MobileAccountService,客户端通过该服务名称就能够进行调用。

下面启动服务端,发布服务,如下所示:


package org.shirdrn.spring.remote.rmi;  
  
import org.springframework.context.support.ClassPathXmlApplicationContext;  
  
public class RmiServer {  
  
public static void main(String[] args) throws InterruptedException {  
new ClassPathXmlApplicationContext("org/shirdrn/spring/remote/rmi/server.xml");  
          
new Object();  
synchronized (lock) {  
            lock.wait();  
        }  
    }  
}


 

客户端调用服务

客户端配置client.xml如下所示:



<?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:p="http://www.springframework.org/schema/p"  
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">  
  
<bean id="mobileAccountService" class="org.springframework.remoting.rmi.RmiProxyFactoryBean">  
<property name="serviceUrl" value="rmi://192.168.1.103:8080/MobileAccountService" />  
<property name="serviceInterface"  
value="org.shirdrn.spring.remote.rmi.AccountService" />  
</bean>  
  
</beans>


配置中,将一个serviceUrl和serviceInterface注入给RmiProxyFactoryBean,即可进行远程方法调用。调用示例如下所示:



package org.shirdrn.spring.remote.rmi;  
  
import org.apache.log4j.Logger;  
import org.springframework.context.ApplicationContext;  
import org.springframework.context.support.ClassPathXmlApplicationContext;  
  
public class RmiClient {  
  
private static final Logger LOG = Logger.getLogger(RmiClient.class);  
      
public static void main(String[] args) {  
new ClassPathXmlApplicationContext(  
"org/shirdrn/spring/remote/rmi/client.xml");  
        AccountService accountService = (AccountService) ctx  
"mobileAccountService");  
"13800138000", (byte) 5);  
        LOG.info(result);  
    }  
  
}


可见,实现远程访问变得非常容易。

标签:集成,rmi,服务,Spring,org,RMI,public,服务端,客户端
From: https://blog.51cto.com/u_809530/8274555

相关文章

  • spring mvc 异常统一处理方式
    springmvc异常统一处理方式springMVC提供的异常处理主要有两种方式,一种是直接实现自己的HandlerExceptionResolver,另一种是使用注解的方式实现一个专门用于处理异常的Controller——ExceptionHandler。1、HandlerExceptionResolver:实现自己的HandlerExceptionResolver,Hand......
  • cmake Ninja 集成试用
    核心比较简单就是添加Ninja的依赖工具,然后再构建的时候指定生成器为Ninja使用安装ninja我使用的mac系统 brewinstallninja生成前提是已经有了一个CMakeLists.tx同时还没有初始化 cmake-GNinja..效果 构建......
  • 关于LINUX权限(启动tomcat)-bash: ./startup.sh: Permission denied
    关于LINUX权限-bash:./startup.sh:Permissiondenied在执行./startup.sh,或者./shutdown.sh的时候,爆出了Permissiondenied,其实很简单,就是今天在执行tomcat的时候,用户没有权限,而导致无法执行,用命令chmod修改一下bin目录下的.sh权限就可以了chmodu+x*.sh在此执行,OK了。......
  • SpringMVC中Velocity的配置
    pom.xml所需velocity的jar<dependency> <groupId>org.apache.velocity</groupId> <artifactId>velocity</artifactId> <version>1.7</version> </dependency> <dependency> <groupId>org.apache.ve......
  • 2023码尚教育接口自动化框架的实现源码分享pytest+allure+jenkins几乎零代码少量的代
    本框架适合对Pytest有大概认识(比如看完X站3天课程的水平),职场新人没有雄厚的资本去参加专业的培训、功能测试转自动化测试、开发转测试的小伙伴们。首先介绍下这个框架的使用,看看是不是你所需要的。第一步、添加模块PY文件,编写接口代码。classTestJuhe: #upwei:fanfanzb2023......
  • Spring mvc中@RequestMapping 6个基本用法小结
    小结下springmvc中的@RequestMapping的用法。 1)最基本的,方法级别上应用,例如:    Java代码  @RequestMapping(value="/departments")public"simplePatternmethodwascalled");return"someResult";}  则访问http://loc......
  • 备份下启动springboot项目脚本文件 start.sh
    1.将jar包放到和该脚本同级目录2.记得chmod777./start.sh赋予执行权限3.执行./start.sh文件即可4.重启也可以直接执行此文件5.如果没有打包配置文件可以在此脚本同级目录创建config目录将yml/properties配置文件放进去. #!/bin/bash#进入脚本所在路径cd`dirname$......
  • 记录一次springboot开启远程调试的问题
    springboot远程连接报错如下Errorrunning'remote':Unabletoopendebuggerport(10.100.10.54:18082):java.net.ConnectException"Connectionrefused:connect"启动命令如下/usr/local/jdk-11.0.11/bin/java-jar-Xms128m-Xmx1024m-Dserver.port=8082-a......
  • IDEA 关闭SpringBoot启动Logo/图标
     一、环境1、SpringBoot2.6.4 MavenPOM格式<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.6.4</version><relativePath/></par......
  • Spring Junit单元测试
    发现通过Spring进行bean管理后,做测试会有各种不足,例如,很多人做单元测试的时候,还要在Before方法中,初始化Spring容器,导致容器被初始化多次。@Beforepublicvoidinit(){newFileSystemXmlApplicationContext("classpath:spring/spring-basic.xml");......