Java Spring RMI一些尝试-低调大师

Java Spring RMI一些尝试

2018-01-19 594

最近在做一个调度服务器的项目,因为各个服务器上面的定时任务比较多,分别执行的话运维检查起来比较麻烦.就想到搞一个专门的调度服务器来统一管理这些任务.因为随时可能增加新的服务器或者新的命令,要是全写在一起每次要把整个程序替换掉,上线不方便.发现spring可以很好的解决这个问题,新加的程序可以以单独jar包的方式添加,只需要修改ApplicationContext就行了,client端只需要改配置就行了程序可以不用改.个人感觉spinrg自身的RMI类比Java自带的好理解一些.

首先是Server端，需要有一个启动函数，以及各命令对应的实现接口,启动类 .为了部署方便期间,配置文件路径直接改外部输入了

public class StartRMIServer {
    public static void startRMIServer(String path) {
        if(path != null && path.startsWith("/")) {
            new FileSystemXmlApplicationContext("/" + path + "applicationContext.xml");
        }else{
            new FileSystemXmlApplicationContext(path + "applicationContext.xml");
        }
        System.out.println("RMI服务端启动！！！");
    }

    public static void main(String[] args) {
        startRMIServer(args[0]);
    }
}

关于FileSystemXmlApplicationContext这里一开始不知道，在Linux下输入的根路径会被当成当前路径处理，去查了之后发现是构造函数会把第一个'/'给去掉，所以这里需要加上.也可以用ClassPathXmlApplicationContext直接以file:开头

然后加入接口和实现类,当客户端发起命令时就会调用该接口,接口对应的实现类由spring定义文件来控制,所以就能够实现不同的命令对应不同的实现类.这里定义了两个不同的实现类

public interface IRmiService{
    String getMsg(String params) throws Exception;
}

调用的类预留一个字符串参数,便于有需要的实现类解析后使用

public class HelloWordService implements IRmiService{
    public String getMsg(String params) throws Exception{
        return "Hello World!"; 
    }
}


public class RealTimeService implements IRmiService {
    public String getMsg(String params){
        return "Real Time!" +  params; 
    }
}

ApplicationContext配置定义如下,两个实现类分别对应不同的命令

　　 <!-- 定义接口实现类 --> 
    <bean id="helloWordService" class="com.cmb.SpringRmi.HelloWordService" scope="prototype"/> 
   
　　 <!-- 定义服务端接口 -->
    <bean class="org.springframework.remoting.rmi.RmiServiceExporter">
        <!-- 将远程接口实现类对象设置到RMI服务中 -->
        <property name="service" ref="helloWordService" />
        <!-- 设置RMI服务名，将作为RMI客户端的调用接口-->
        <property name="serviceName" value="helloWord" />
        <!-- 将远程接口设置为RMI服务接口 -->
        <property name="serviceInterface" value="com.cmb.SpringRmi.IRmiService" />
        <!-- 为RMI服务端远程对象注册表设置端口号-->
        <property name="registryPort" value="9090" />
    </bean>

　　 <bean id="realTimeService" class="com.cmb.SpringRmi.RealTimeService" scope="prototype"/>
    <bean class="org.springframework.remoting.rmi.RmiServiceExporter">
        <property name="service" ref="realTimeService" />
        <property name="serviceName" value="realTime" />
        <property name="serviceInterface" value="com.cmb.SpringRmi.IRmiService" />
        <property name="registryPort" value="9090" />
    </bean>

这样server端就配置完成了,可以直接启动试一下

client端相当于是每次给server发一个请求命令,server端接收到之后去执行对应的实现类.我这边实现类加了log4j功能,参数是context路径,命令和命令对应的参数

public class RMIClient {
    public static void main(String[] args) {
        ApplicationContext ctx = new ClassPathXmlApplicationContext("file:" + args[0] + "/applicationContext.xml");
        IRmiServer helloWord = (IRmiServer) ctx.getBean(args[1]);
        LogBean log = (LogBean) ctx.getBean("log");
        PropertyConfigurator.configure(log.getPath());
        Logger logger = Logger.getLogger(RMIClient.class);
        logger.info("Call " + args[1]);
        try {
            String params = "";
            if (args.length > 2 && args[2] != null && !"".equals(args[2])) {
                params = args[2];
            }
            logger.info(helloWord.getMsg(params));
            logger.info(args[1] + " succeed");
        } catch (Exception e) {
            e.printStackTrace();
            logger.error(e.getMessage(), e);
            System.exit(1);
        }
    }
}

接口名字其实不需要和server端一样

public interface IRmiServer{
    String getMsg(String params) throws Exception;
}

spring设置如下,这里设置了两条命令helloWorld和printDate,分别对应类HelloWordService和RealTimeService

    <!--bean id为程序调用时输入的第一参数-->    
    <bean id="helloWord" class="org.springframework.remoting.rmi.RmiProxyFactoryBean"> 
        <!--ip和端口为server的ip和刚才注册的端口号,服务名为设置的serviceName-->
        <property name="serviceUrl" value="rmi://localhost:9090/helloWord"/>
        <!--调用的接口-->
        <property name="serviceInterface" value="com.cmb.SpringRmiClient.IRmiServer"/>
        <!-- 当连接失败时是否刷新远程调用stub -->
        <property name="refreshStubOnConnectFailure" value="true"/>
    </bean>
    
    <bean id="printDate" class="org.springframework.remoting.rmi.RmiProxyFactoryBean"> 
        <property name="serviceUrl" value="rmi://localhost:9090/realTime"/>
        <property name="serviceInterface" value="com.cmb.SpringRmiClient.IRmiServer"/>
        <property name="refreshStubOnConnectFailure" value="true"/>
    </bean>

此时就可以执行client,可以看到如果输入的命令不同,打印出的结果是不同的,说明调用的实现类不同.

部署的时候采用命令行指定java.ext.dirs的方式,这样可以把所有相关的程序jar包都放到文件夹里面,便于后续扩展程序的部署.

java -Djava.ext.dirs="rmiclient/lib" -jar rmiclient/rmiclient.jar D:/test/rmiclient printDate

关于后续添加部署.我现在想要添加一个程序,那么应该把这个jar包放置到server上的lib目录中,把server进程结束,然后在server的ApplicationContext增加一组bean,client的ApplicationContext也对应增加一组,重启之后就可以使用新的程序了.

通过这个小工具的开发对spring工厂和IOC有了些了解,后面要多研究吃透spring

个人GitHub地址: https://github.com/GrayWind33

微信关注我们

原文链接：https://yq.aliyun.com/articles/625232

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

PHP5.5面向对象连接mysqli(循环读取数据)

<?php // 系统设置 include '/config.inc.php'; // 连接并选择数据库 $mysqli = new mysqli(DATABASE_HOSTNAME, DATABASE_USERNAME, DATABASE_PASSWORD, DATABASE_DATANAME); // 判断连接是否成功 if ($mysqli->connect_errno) { printf("不能连接数据库，错误是: %s\n", $mysqli -> connect_error); exit(); } // SQL查询语句 $sql = "select * from Company_Info"; // 运行SQL查询 if ($result = $mysqli -> query($sql)) { // 读取数据 while ($row = $result -> fetch_array(MYSQLI_ASSOC)) { // 读取特定字段 $CompanyName = $row['Compa...

2018-01-20

493

Java常见面试题及答案 21-30（JVM）(集合类)HashMap

21.HashMap的工作原理是什么? HashMap内部是通过一个数组实现的，只是这个数组比较特殊，数组里存储的元素是一个Entry实体(jdk 8为Node)，这个Entry实体主要包含key、value以及一个指向自身的next指针。HashMap是基于hashing实现的，当我们进行put操作时，根据传递的key值得到它的hashcode，然后再用这个hashcode与数组的长度进行模运算，得到一个int值，就是Entry要存储在数组的位置（下标）；当通过get方法获取指定key的值时，会根据这个key算出它的hash值（数组下标），根据这个hash值获取数组下标对应的Entry，然后判断Entry里的key，hash值或者通过equals()比较是否与要查找的相同，如果相同，返回value，否则的话，遍历该链表（有可能就只有一个Entry，此时直接返回null），直到找到为止，否则返回null。 HashMap之所以在每个数组元素存储的是一个链表，是为了解决hash冲突问题，当两个对象的hash值相等时，那么一个位置肯定是放不下两个值的，于是hashmap采用链表来解决这种冲...

2018-01-20

358

发表评论

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。