RabbitMq使用demo[通俗易懂]

RabbitMq使用demo[通俗易懂]1.为什么使用mq2.常见的mq有哪几种3.RabbitMq使用配置4.RabbitMq使用demo4.总结5.参考

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

1. 为什么使用mq

        我们平时的程序多数都是同步的,常见的RestApi,都是同步的调用。在处理异步的请求时,适合采用消息中间件。特别是涉及到一些跨系统的调用,而且在处理一些高并发问题的时候,也可以采用mq队列的串行特征,使得开发简单。此外,mq的订阅模式,适用于在消费生产者发出信息时不知道有多少消费者时,这种模式完美适用。

2. 常见的mq有哪几种

        常见的mq主要有activemq,rabbitmq,rocketmq

        activemq

        是Apache出品的,是一个完全支持JMS规范的JSMProvider实现。提供客户端支持跨语言和协议。它能够以代理人和点对点的技术实现队列。

        rabbitmq

        是使用Erlang编写的一个开源的消息队列,本身支持很多协议AMQP,XMPP,SMTP,STOMP,也正是因为支持这么多的协议,使得它很重量级,更适合企业级的开发。它采用经纪人(broker)架构,这意味着消息在发送给客户端时,先在中心队列排队。对路由(routing)和负载均衡(load balance)和数据持久化都有很好的支持。

        rocketmq

        是阿里巴巴开源的一个消息中间件框架(阿里内部称为MetaQ),于2012年开源,并在2017年正式成为Apache的顶级项目。

3. RabbitMq使用配置

rabbitmq(安装)。

RabbitMq使用demo[通俗易懂]

安装好后默认的web访问地址是

http://127.0.0.1:15672

使用java连接的默认端口是5672

默认的用户名和密码是:guest/guest

4. RabbitMq使用demo

添加pom配置

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

修改配置文件application.yml

spring:
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
    publisher-confirms: true

新增配置类

@Configuration
public class RabbitConfig {

    @Bean
    public Queue Queue() {
        return new Queue("logOper");
    }

}

生产者

@Service
@Slf4j
public class LogProducer {
	
	@Autowired
	private AmqpTemplate rabbitTemplate;

	public void send(LogOper logOper) {
		log.info("Sender logOper: " + logOper.toString());
		rabbitTemplate.convertAndSend("logOper", logOper);
	}

}

消费者

@Slf4j
@Component
@RabbitListener(queues = "logOper")
public class LogConsumer {

	@Autowired
	private LogOperDao logOperDao;

	@RabbitHandler
	public void process(LogOper logOper) {
		log.info("Receiver logOper : " + logOper);
		logOperDao.addLogOper(logOper);
	}

}

4. 总结

        上面只是简单的一对一形式的使用,rabbitmq实际上是支持多种模式比如一对多,多对一,多对多模式的场景。只需修改少量的配置就可以完成,后面再具体进行分析。

5. 参考

RocketMQ实战(一)

RabbitMQ学习笔记

springboot+rabbitmq整合示例程

spring boot实战(第十二篇)整合RabbitMQ

RabbitMQ 使用参考

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/186196.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • Python识别图片中的文字「建议收藏」

    Python识别图片中的文字「建议收藏」不知道大家有没有遇到过这样的问题,就是在某个软件或者某个网页里面有一篇文章,你非常喜欢,但是不能复制。或者像百度文档一样,只能复制一部分,这个时候我们就会选择截图保存。

  • 创建线程:pthread_create

    创建线程:pthread_create

  • 外地人在北京的真实状态(漫画)

    这就是外地人在北京的真实状态! 北京这个城市看似中国的首都,实则在这里很不容易,但是感谢阿Q的存在,能把这种苦逼包装成一种高大上的状态。早上每天5:30起床睡眠不足,我们包装成早期…

  • js数组拼接的四种方法[通俗易懂]

    js数组拼接的四种方法[通俗易懂]vara=[1,2,3,4,5,6];varb=[&quot;foo&quot;,&quot;bar&quot;,&quot;fun&quot;];最终的结果是:[1,2,3,4,5,6,&quot;foo&quot;,&quot;bar&quot;,&quot;fun&quot;]方法1:concatc=a.concat(b);c是新数组,此时内存使用有,c,a,b三个数组。方法2:

  • Mysql忘记密码和密码重置

    Mysql忘记密码和密码重置**Mysql忘记密码和密码重置**环境:系统Windows10MySQL-8.0.23操作步骤:1、停止MySQL服务打开命令窗口cmd,输入命令:netstopmysql,停止MySQL服务2、开启跳过密码验证登录的MySQL服务打开命令窗口cmd,进入mysql安装目录下的bin目录,然后输入如下这条命令`mysqld–shared-memory–skip-grant-tables`3、重新打开一个cmd命令窗口,输入mysql命令就可以直接登录了,直接

  • servlet-EL表达式与JSTL标签「建议收藏」

    servlet-EL表达式与JSTL标签「建议收藏」EL表达式EL表达式的作用:EL表达式主要是代替jsp页面中的表达式脚本在jsp页面中进行数据输出。因为EL表达式在输出数据的时候,要比jsp表达式脚本要简洁的多格式$(表达式)<%@ page import=”java.util.Map” %><%@ page import=”java.util.HashMap” %><%@ page contentType=”text/html;charset=UTF-8″ language=”java” %><h

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号