[学习交流] 【广州校区】+【原创】+springboot+rabbitMQ实现RPC远程调用

如题，我们要使用Spring Boot和RabbitMQ实现RPC远程调用，那么首先要了解RPC。RPC，即Remote Procedure Call Protocol 远程过程调用协议，在大型的公司，系统一般都是由大大小小的服务构成，不同的团队维护不同的代码，部署在不同的机器。但是在做开发时候往往要用到其它团队的方法，因为已经有了实现。但是这些服务部署不同的机器上，想要调用就需要网络通信，这些代码繁琐且复杂，一不小心就会写的很低效。RPC协议定义了规划，其它的公司都给出了不同的实现。而现在我们不使用其他公司的实现，直接使用消息中间件RabbitMQ进行实现。现在有这样的一个业务场景，在一个商城系统中，用户在订单微服务中购买商品成功之后会给用户相应的积分，而积分系统是另外一个微服务，两个微服务之间的调用之前是使用ribbon+eureka+feign进行调用的，现在我们使用这样的逻辑，将它改造成使用RabbitMQ进行RPC调用：

1.创建工程
创建两个微服务工程order和integral，引入相同的依赖：

[XML] 纯文本查看 复制代码

<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.1.RELEASE</version>
	</parent>
	<!-- 管理依赖 -->
	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Finchley.M7</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>
	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<!-- SpringBoot整合RabbitMQ客户端 -->
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-amqp</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
		</dependency>
	</dependencies>
	<repositories>
		<repository>
			<id>spring-milestones</id>
			<name>Spring Milestones</name>
			<url>https://repo.spring.io/libs-milestone</url>
			<snapshots>
				<enabled>false</enabled>
			</snapshots>
		</repository>
	</repositories>

2.工程配置文件
在order微服务中创建配置文件application.yml:

[XML] 纯文本查看 复制代码

server:
  port: 8010
spring:
  application:
    name: app-member
####  RabbitMq配置
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

在积分微服务integral中添加配置文件：

[XML] 纯文本查看 复制代码

server:
  port: 8090
serviceId
spring:
  application:
    name: app-member
####  RabbitMq配置
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
    listener:
      simple:
        retry: 
          max-attempts: 3
          enabled: true

3.创建消息生产者和消费消息的监听者
在订单微服务order中创建消息生产者：

[Java] 纯文本查看 复制代码

@RestController
public class QueenSender {
	@Autowired
	private AmqpTemplate rabbiTemplate;
	/**
	 * 
	 * @Title: sendMesage   
	 * @Description: TODO发送消息
	 * @param: @param message      
	 * @return: void      
	 * @throws
	 */
	@RequestMapping("/testMq")
	public void sendMesage(String message) {
		
		System.out.println("购物成功，向积分系统发送消息:"+message+",添加积分");
		rabbiTemplate.convertAndSend("testExchange","testRabbitKey",message);
	}

}

创建启动类：

[Java] 纯文本查看 复制代码

@SpringBootApplication
public class RabbitProviderApp {

	public static void main(String[] args) {
		SpringApplication.run(RabbitProviderApp.class, args);
	}

}

在积分微服务中创建消息监听者：

[Java] 纯文本查看 复制代码

@Component
public class RabbitMqListener {

	@RabbitListener(bindings = @QueueBinding(
			value = @Queue(value = "hello", durable = "true"), 
			exchange = @Exchange(value = "testExchange", type = "topic", durable = "true"), 
			key = "testRabbitKey"))
	public void receiveMessage(String message) {
			System.out.println("这里是积分微服务，接收到消息："+message);
	}

}

注意：使用@RabbitListener监听指定队列、指定exchange、指定routingKey的消息，同时@RabbitListener有建立队列、exchange、routingKey的功能
创建启动类：

[Java] 纯文本查看 复制代码

@SpringBootApplication
public class RabbitMQApp {
	public static void main(String[] args) {
		SpringApplication.run(RabbitMQApp.class, args);
	}

}

4.测试
先启动积分微服务，再启动订单微服务，在浏览器中输入http://localhost:8010/testMq?message=123，发现订单微服务控制台输出：
购物成功，向积分系统发送消息:123,添加积分
而在积分微服务的控制台输出：
这里是积分微服务，接收到消息：123
测试成功。

帐号		自动登录	找回密码
密码			加入黑马

[学习交流] 【广州校区】+【原创】+springboot+rabbitMQ实现RPC远程调用

0 个回复