多语言展示
当前在线:372今日阅读:183今日分享:19

java 实现spring+RabbitMQ RPC 集成

本文主要介绍如何使用spring 集成RabbitMQ 实现RPC 调用。
工具/原料
1

笔记本,jdk ,Eclispe

2

RabbitMQ 服务器

方法/步骤
1

使用开发工具Eclipse 创建RPC客户端项目。组织结构如下图:

2

接口声明:RpcSpringTest .javapackage com.cn.trap.test;public interface RpcSpringTest {    public void sayHi(String name);}

3

客户端配置文件:applicationContext.xml                                                      

4

客户端启动类测试类: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");    }}

5

使用开发工具创建RPC服务端项目,项目截图如下:

6

服务端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);    }}

7

服务端项目spring配置:applicationContext.xml                                                                                                                                                     

8

服务端服务启动类:public class Application {    private static volatile ApplicationContext ctx;    public static void main(String[] args) {        ctx = new ClassPathXmlApplicationContext("applicationContext.xml");                }}

注意事项
1

在调用之前需将服务端项目RPC服务启动。

2

spring配置文件中有相关RabbitMQ配置参数,如IP地址,端口号,用户名,密码,根据自己服务的地址进行相关修改。

3

RabbitMQ 实现RPC调用时会创建临时队列,效率上可能不如固定队列。

推荐信息