springboot2 springcloud Greenwich.SR3 构建微服务--5.rabbitMQ的使用

2024-05-13 16:48
文章标签 java 服务 使用 构建 spring springcloud rabbitmq springboot2 greenwich sr3

本文主要是介绍springboot2 springcloud Greenwich.SR3 构建微服务--5.rabbitMQ的使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

其实在统一配置中心的时候就应该开始说rabbitmq 了, 但是没有说, 所以这里专门说下rabbitmq.

rabbitmq 在配置中心作为消息的传递来使用了.

 

rabbitmq的原理, 具体使用, 请查阅这个

https://blog.csdn.net/u010398771/article/details/84136959

 

现在的mq开源的不要太多了, 我最先用的activemq, 后来阿里开源的rocketmq,

还有 kafka, rabbitmq. 最近看新闻,腾讯也开源了他们用java写的MQ, 名字不记得了...又是个亿万级别的服务, 牛掰哄哄的样子

其实rabbitMQ的安装很简单, 这里就不推荐大家先下载erlang 再安装rabbitmq 了, 更不推荐你去编译源码安装, 因为我安装过一次, 装的时候,电脑卡, 时间又长, 你可以直接在你的docker里面安装一个rabbitmq, 就可以使用了,很方便.

docker安装rabbitmq, 先搜索目前的镜像

docker search rabbitmq

先拉取下来, 再创建容器运行.注意拉取带有management 的rabbitmq , 这是带控制带的版本.

#拉取镜像
docker pull rabbitmq:3.7.17-management#运行
docker run -d -p 5672:5672 -p 15672:15672 --name myrabbitmq rabbitmq:3.7.17-management

登陆网页端, http://localhost:15672,  用户名和密码都是guest, 就可以看到了管理页面了, 可以看到目前没有消息到来和消费

 

rabbitmq的使用

1.添加依赖

 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2.添加配置文件

#rabbitmq的配置
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
#解决input 和 output中重名bean问题,需要配置这个....
spring.cloud.stream.bindings.input.destination: raw-sensor-data
spring.cloud.stream.bindings.output.destination: raw-sensor-data

 

2.1. queue 的  bean的配置

//名字都变成常量
public class MessageConstant {public final static String INPUT = "input";public final static String OUTPUT = "output";public final static String QUEUE_NAME = "myQueue";}
/*** 注入一个queue, 不要去手动创建!*/@Beanpublic Queue queue(){return new Queue(MessageConstant.QUEUE_NAME,true);}

3.就开始发送和接收消息了.


import com.example.order.constans.MessageConstant;
import com.example.order.dto.OrderDTO;
import com.example.order.message.StreamClient;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;import java.time.LocalDateTime;/*** @author zk* @Description:* @date 2019-09-20 16:24*/
@RestController
public class SendMessageController {/*** 往rabbitmq发送消息*/@Autowiredprivate AmqpTemplate amqpTemplate;@GetMapping("send")public String sendMessage() {//需要实现创建一个myQueue的队列amqpTemplate.convertAndSend(MessageConstant.QUEUE_NAME, "this is the first message");
//第二种消息发送amqpTemplate.convertAndSend("myOrder", "computer", "this is the first computer  message");amqpTemplate.convertAndSend("myOrder", "fruit", "this is the first message");return "success";}@Autowired(required = false)private StreamClient streamClient;/*** 发送字符串对象** @return*//*@GetMapping("send2")public String send2() {String msg = "time  is today, haha ";System.out.println("发送的消息是:" + msg);streamClient.output().send(MessageBuilder.withPayload(msg).build());return "success";}*//*** 发送java bean对象* 这个send3 不能和send2 使用的同一个变量.但是不能共存, 需要注释掉, 不然报错的...** @return*/@GetMapping("send3")public String send3(){OrderDTO dto = new OrderDTO();dto.setBuyerAddress("address");dto.setBuyerName("xiexin");streamClient.output().send(MessageBuilder.withPayload(dto).build());return "success";}}

4.消息接收端


import com.example.order.constans.MessageConstant;
import com.example.order.dto.OrderDTO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;/*** @author zk* @Description: 接受消息* @date 2019-09-20 16:21*/
@Component
@EnableBinding(StreamClient.class)
public class StreamReceiver {/*** 接受字符串*//*@StreamListener(MessageConstant.INPUT)public void process(Object msg) {System.out.println(msg);}*//*** 接受orderDTO对象*/@StreamListener(MessageConstant.INPUT)@SendTo(MessageConstant.OUTPUT)//处理完消息,再回发送个消息public Object process(OrderDTO msg) {System.out.println(msg);//发送消息return "这是消息";}/*** 接受上面的回传的消息*/@StreamListener(MessageConstant.OUTPUT)public void process2(String msg) {System.out.println(msg);}}

import com.example.order.constans.MessageConstant;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;/*** @author zk* @Description:mq 接收消息* @date 2019-09-20 15:29*/
@Component
public class MQReceiver {//1.手动创建队列//@RabbitListener(queues= MessageConstant.QUEUE_NAME)//2.自动创建队列//@RabbitListener(queuesToDeclare = @Queue(MessageConstant.QUEUE_NAME))//3.自动创建 exchange 和 queue绑定@RabbitListener(bindings = @QueueBinding(value = @Queue(MessageConstant.QUEUE_NAME),exchange = @Exchange("myExchange")))public void process(String message){System.out.println("接收到的消息是:"+message);}/*** 按照exchange 和 key 进行匹配.* 数码消息接受商* @param message*/@RabbitListener(bindings = @QueueBinding(exchange = @Exchange("myOrder"),key = "computer",value = @Queue("computerOrder")))public void computerProcess(String message){System.out.println("computer接收到的消息是:"+message);}/*** 水果消息接受商* @param message*/@RabbitListener(bindings = @QueueBinding(exchange = @Exchange("myOrder"),key = "fruit",value = @Queue("fruitOrder")))public void fruitProcess(String message){System.out.println("fruit接收到的消息是:"+message);}}

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import com.example.product.entity.ProductInfo;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;import java.util.HashMap;
import java.util.List;
import java.util.Map;@Component
public class ProductInfoReceiver {private final static String HASH_KEY="product_stock";@Autowiredprivate StringRedisTemplate stringRedisTemplate;/*** 传递整个对象的方法* @param message*///@RabbitListener(queuesToDeclare = @Queue("productInfo"))public void process0(String message) {//注意反序列化的时候,两个对象的前缀要求是一样的(包名)//ProductInfo info = JSON.parseObject(message, ProductInfo.class);List<ProductInfo> infos = JSON.parseObject(message, new TypeReference<List<ProductInfo>>() {});System.out.println("接受到的消息是:" + infos);//存储到redis中去.//stringRedisTemplate.opsForValue()// .set("product_stock_" + info.getProductId(), String.valueOf(info.getProductStock()));/*** 单值的key -value 可以储存, 现在多个的时候, 最好使用hash 的方式进行存储* 这种单值的存储方式不好...* product_stock        1       5*      key           field   value*/for (ProductInfo info : infos) {stringRedisTemplate.opsForHash().put(HASH_KEY,info.getProductId(),info.getProductStock());}}/*** 只传递id和剩余库存的方法* 这里的参数的接收对象一定和发送的一致,不然rabbitmq会报类型转换错误.* json转换后,就是json的数组或者json字符串了.上面的那个方法是个反例* @param message*/@RabbitListener(queuesToDeclare = @Queue("productInfo"))public void process(Map<String,Integer> message) {//注意反序列化的时候,两个对象的前缀要求是一样的(包名)System.out.println("接受到的消息是:" + message);//存储到redis中去.//stringRedisTemplate.opsForValue()// .set("product_stock_" + info.getProductId(), String.valueOf(info.getProductStock()));/*** 单值的key -value 可以储存, 现在多个的时候, 最好使用hash 的方式进行存储* 这种单值的存储方式不好...* product_stock        1       5*      key           field   value*/for (Map.Entry<String, Integer> entry : message.entrySet()) {stringRedisTemplate.opsForHash().put(HASH_KEY,entry.getKey(),String.valueOf(entry.getValue()));}}}

import com.example.order.constans.MessageConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;/*** @author zk* @Description:* @date 2019-09-20 16:19*/
public interface StreamClient {/*** 这里的input 和 output 必须是不同的字符串, 不然是同名的bean错误*/@Input(MessageConstant.INPUT)SubscribableChannel input();@Output(MessageConstant.OUTPUT)MessageChannel output();}

rabbitmq 的消息是根据 queue  exchange  key 做的分类存储,

所以上面的myqueue中的不同的key 会得到不同的接收者那里去.

 

 

 突然觉得我好懒啊, 不愿意好好写博客, 想各种偷懒, 这东西更像在写自己的随手笔记了,而不是在写让大部分都能够看懂的博客. 

随便代码往这里一贴, 然后加几句解释就完事了, 不讲原理, 因为不想打字.  不想说流程, 因为懒的去画很好看的图出来, 懒的理由还很充分! .

甚至这一系列的博文中可能一些小章节中有误,  看了代码应该运行不起来, 但是我还是贴出来, 某些还涉及到其他地方的点滴, 没有在博客中体现出来, 感觉我就是在发垃圾博客!!!! 

这次一口气写十篇关于springcloud 的博文, 但是现在看起来, 估计写完后质量非常的差. 完全不是我想象的那样子,既能够自己总结, 又能帮助别人提高.

反思下自己!!!! 

不过写文章确实很花时间, 就这种水平的博客, 想写一个出来, 也差不多得花10分钟 ! 所以有了对这10篇博客的重新修改

 

整个代码地址是:

https://github.com/changhe626/micro-service

Java Framework,欢迎各位前来交流java相关
QQ群:965125360
 

 

 

这篇关于springboot2 springcloud Greenwich.SR3 构建微服务--5.rabbitMQ的使用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/986270。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
中文分词jieba库的使用与实景应用（一）

中文分词jieba库的使用与实景应用（一）

知识星球：https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义： 精确模式（默认模式）： 全模式： 搜索引擎模式： paddle 模式（基于深度学习的分词模式）： 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取
阅读更多...
使用SecondaryNameNode恢复NameNode的数据

使用SecondaryNameNode恢复NameNode的数据

1）需求： NameNode进程挂了并且存储的数据也丢失了，如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2）故障模拟 （1）kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 （2）删除NameNode存储的数据（/opt/module/hadoop-3.1.4/data/tmp/dfs/na
阅读更多...
Hadoop数据压缩使用介绍

Hadoop数据压缩使用介绍

一、压缩原则 （1）运算密集型的Job，少用压缩 （2）IO密集型的Job，多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1）为了支持多种压缩/解压缩算法，Hadoop引入了编码/解码器 2）要在Hadoop中启用压缩，可以配置如下参数
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2