热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

开发笔记:rabbitmq基础入门

本文由编程笔记#小编为大家整理,主要介绍了rabbitmq-基础入门相关的知识,希望对你有一定的参考价值。 在学东西之前,我们先有一个方法论,知道如何学习。学习一个东西一般都遵循以下几个环节:xxx
本文由编程笔记#小编为大家整理,主要介绍了rabbitmq-基础入门相关的知识,希望对你有一定的参考价值。



在学东西之前,我们先有一个方法论,知道如何学习。学习一个东西一般都遵循以下几个环节:

  1. xxx是什么,诞生的原因,能解决什么问题。

  2. 如何安装,如何使用(快起启动一个demo)。

  3. 涉及到的一些基础概念介绍和基础入门使用。

  4. 中阶、高阶的功能特性使用。

  5. 高可用部署方案。

  6. 原理的深入理解。


这篇文章主要处于第一、二环节,让新手更好得入门。


1、rabbitmq是什么

rabbitmq 是目前非常热门的一款消息中间件。Rabbit 这样名字,是因为兔子行动非常迅速且繁殖起来非常疯狂, RabbitMQ 的开创者认为以此命名这个分布式软件再合适不过了。

RabbitMQ 是采用 Erlang 语言实现 AMQP (Advanced Message Queuing Protocol,高级消息队列协议)的消息中间件,它最初起源于金融系统,所以rabbitmq的特点是可靠性传输,性能在可靠性后面


2、为什么要使用mq,为什么要选rabbitmq


为什么要使用mq?

mq一般有两种模式
一种是点对点模式:主要是为了削峰和异步。
另一种是广播模式:主要是为了业务之间的解耦。

简单说就是业务有需要对流量削峰的场景,有需要对业务解耦场景。


为什么要选rabbitmq?

rabbitmq的特点如下:
1、可靠性: RabbitMQ是为了金融系统而生, 所以特地使用一些机制来保证可靠性,如持久化、传输确认及发布确认等。
2、灵活的路由器:4种路由器
3、扩展性:多个 rabbitmq 节点可以组成个集群,也可以根据实际业务情况动态地扩展集群中节点。
4、高可用:拥有镜像队列防止容灾消息丢失。

让我们使用mq产品做重要的业务处理(例如金额、订单)的时候,我们最基本的述求是
1、可靠稳定,消息不丢失。
2、有集群容灾方案。
3、灵活的功能特性。
4、性能在可靠的基础上
rabbitmq都能完美胜任。


4、rabbitmq的安装

这里只介绍docker安装方式
docker run -d --name myrabbit1 -p 15672:15672 -p 5672:5672 rabbitmq:3.6.15-management

安装之后访问 localhost:15672(localhost改服务器ip)见到如下界面代表安装成功。
技术图片
使用默认账号guest/guest登录

技术图片

管理台的界面后续再一个一个地方详细讲解。

4、快速使用的demo
这里以springboot为例子展示如何快速使用rabbitmq
4.1 新建springboot工程同时增加配置

spring.rabbitmq.host=localhost
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

4.2 引入ampq的springboot-start依赖


org.springframework.boot
spring-boot-starter-web


org.springframework.boot
spring-boot-starter-amqp

4.3 新建配置文件,初始化队列

@Configuration
public class RabbitMqConfig {
@Bean
public Queue demo(){
Queue demo = new Queue("demo");
return demo;
}
}

4.4 新建消费者、生产者。

@RestController
@RequestMapping
public class Controller {
@Autowired
private RabbitTemplate rabbitTemplate;
@GetMapping("sendMq")
public String sendMq(String msg){
rabbitTemplate.convertAndSend("demo",msg);
return msg;
}
}

@Component
public class DemoLister {
@RabbitListener(queues = "demo")
public void Lister(Message message){
byte[] body = message.getBody();
System.out.println("接受到的消息体:"+new String(body));
}
}

4.5 发送消息查看效果
执行命令curl localhost:8080/sendMq?msg=abc
查看效果
技术图片

5、最后
git clone -b teacher-1 https://gitee.com/guoeryyj/rabbitmq-teacher.git下载试例代码x






















推荐阅读
  • 现在比较流行使用静态网站生成器来搭建网站,博客产品着陆页微信转发页面等。但每次都需要对服务器进行配置,也是一个重复但繁琐的工作。使用DockerWeb,只需5分钟就能搭建一个基于D ... [详细]
  • {moduleinfo:{card_count:[{count_phone:1,count:1}],search_count:[{count_phone:4 ... [详细]
  • 本文介绍了Web学习历程记录中关于Tomcat的基本概念和配置。首先解释了Web静态Web资源和动态Web资源的概念,以及C/S架构和B/S架构的区别。然后介绍了常见的Web服务器,包括Weblogic、WebSphere和Tomcat。接着详细讲解了Tomcat的虚拟主机、web应用和虚拟路径映射的概念和配置过程。最后简要介绍了http协议的作用。本文内容详实,适合初学者了解Tomcat的基础知识。 ... [详细]
  • 加密世界下一个主流叙事领域:L2、跨链桥、GameFi等
    本文介绍了加密世界下一个主流叙事的七个潜力领域,包括L2、跨链桥、GameFi等。L2作为以太坊的二层解决方案,在过去一年取得了巨大成功,跨链桥和互操作性是多链Web3中最重要的因素。去中心化的数据存储领域也具有巨大潜力,未来云存储市场有望达到1500亿美元。DAO和社交代币将成为购买和控制现实世界资产的重要方式,而GameFi作为数字资产在高收入游戏中的应用有望推动数字资产走向主流。衍生品市场也在不断发展壮大。 ... [详细]
  • web.py开发web 第八章 Formalchemy 服务端验证方法
    本文介绍了在web.py开发中使用Formalchemy进行服务端表单数据验证的方法。以User表单为例,详细说明了对各字段的验证要求,包括必填、长度限制、唯一性等。同时介绍了如何自定义验证方法来实现验证唯一性和两个密码是否相等的功能。该文提供了相关代码示例。 ... [详细]
  • SpringBoot整合SpringSecurity+JWT实现单点登录
    SpringBoot整合SpringSecurity+JWT实现单点登录,Go语言社区,Golang程序员人脉社 ... [详细]
  • Centos下安装memcached+memcached教程
    本文介绍了在Centos下安装memcached和使用memcached的教程,详细解释了memcached的工作原理,包括缓存数据和对象、减少数据库读取次数、提高网站速度等。同时,还对memcached的快速和高效率进行了解释,与传统的文件型数据库相比,memcached作为一个内存型数据库,具有更高的读取速度。 ... [详细]
  • Centos7搭建ELK(Elasticsearch、Logstash、Kibana)教程及注意事项
    本文介绍了在Centos7上搭建ELK(Elasticsearch、Logstash、Kibana)的详细步骤,包括下载安装包、安装Elasticsearch、创建用户、修改配置文件等。同时提供了使用华为镜像站下载安装包的方法,并强调了保证版本一致的重要性。 ... [详细]
  • 本文记录了作者对x265开源代码的实现与框架进行学习与探索的过程,包括x265的下载地址与参考资料,以及在Win7 32 bit PC、VS2010平台上的安装与配置步骤。 ... [详细]
  • springboot启动不了_Spring Boot + MyBatis 多模块搭建教程
    作者:枫本非凡来源:www.cnblogs.comorzlinp9717399.html一、前言1、创建父工程最近公司项目准备开始重构,框 ... [详细]
  • ejava,刘聪dejava
    本文目录一览:1、什么是Java?2、java ... [详细]
  • 容器管理与容器监控influxDB
    容器管理与容器监控-influxDB什么是influxDBinfluxDB安装(1)下载镜像(2)创建容器(3 ... [详细]
  • ps:写的第一个,不足之处,欢迎拍砖---只是想用自己的方法一步步去实现一些框架看似高大上的小功能(比如说模型中的toArraytoJsonsetAtt ... [详细]
  • 大坑|左上角_pycharm连接服务器同步写代码(图文详细过程)
    篇首语:本文由编程笔记#小编为大家整理,主要介绍了pycharm连接服务器同步写代码(图文详细过程)相关的知识,希望对你有一定的参考价值。pycharm连接服务 ... [详细]
  • Hadoop2.6.0 + 云centos +伪分布式只谈部署
    3.0.3玩不好,现将2.6.0tar.gz上传到usr,chmod-Rhadoop:hadophadoop-2.6.0,rm掉3.0.32.在etcp ... [详细]
author-avatar
粉爱_粉爱陈小翔
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有