笔记本,jdk ,Eclispe
RabbitMQ 服务器
使用开发工具Eclipse 创建RPC客户端项目。组织结构如下图:
接口声明:RpcSpringTest .javapackage com.cn.trap.test;public interface RpcSpringTest { public void sayHi(String name);}
客户端配置文件:applicationContext.xml
客户端启动类测试类:package com.cn.trap.main;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.cn.trap.test.RpcSpringTest;public class Application { private static volatile ApplicationContext ctx; public static void main(String[] args) { ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); System.out.println("服务已启动---"); RpcSpringTest service = ctx.getBean(RpcSpringTest.class); service.sayHi("name"); }}
使用开发工具创建RPC服务端项目,项目截图如下:
服务端RPC接口声明和实现类:RpcSpringTest.javapackage com.cn.trap.test.rpc;public interface RpcSpringTest { public void sayHi(String name);}RpcSpringTestImpl.javapackage com.cn.trap.test.rpc;public class RpcSpringTestImpl implements RpcSpringTest { @Override public void sayHi(String name) { System.out.println("请求收到---"+name); }}
服务端项目spring配置:applicationContext.xml
服务端服务启动类:public class Application { private static volatile ApplicationContext ctx; public static void main(String[] args) { ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); }}
在调用之前需将服务端项目RPC服务启动。
spring配置文件中有相关RabbitMQ配置参数,如IP地址,端口号,用户名,密码,根据自己服务的地址进行相关修改。
RabbitMQ 实现RPC调用时会创建临时队列,效率上可能不如固定队列。