ICode9

精准搜索请尝试: 精确搜索
  • SpringBoot整合rabbitMQ2022-08-05 12:31:33

    生产者: 1.创建生产者SpringBoot工程 2.引入依赖坐标 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 3.编写yml文件,基本信息配置 # 配置

  • RabbitMQ知识简单理解2022-08-03 00:35:32

    官网链接:http://next.rabbitmq.com/getstarted.html 官网给出了每种工作模式的实例代码,可以参考其中的实现 一、RabbitMQ整体架构图    二、RabbitMQ六种工作模式 1、https://www.cnblogs.com/lovelsl/articles/15269124.html 2、https://blog.csdn.net/weixin_44399790/articl

  • rabbitmq概念总结2022-08-03 00:03:03

    rabbitmq是一种消息中间件,需要掌握的核心概念是publish, subscribe, broker, virtual host, exchange, queue, routing key. publish: 生产者向broker发送消息 subscribe: 消费者从queue中取消息,一个queue可能对应多个exchange。 exchange在接收到消息时,会根据routing key将消息分

  • NetCore+RabbitMQ2022-08-02 18:03:14

    1.首先要清楚什么是RabbitMQ,是干啥用的?   RabbitMQ就是一个消息中间件,那什么又是中间件呐?我的理解是,消息中转站,生产者生产完消息,放入中转站,就接着干别的事情去了。 至于你什么时候消费,就看你自己了,一旦消费成功,中间件将不再存储你的消息。类似我们生活中的菜鸟驿站。 厂家就是生

  • RABBITMQ之一概念解释(信道、交换器和路由键、队列)2022-07-29 09:04:43

    RABBITMQ之一概念解释(信道、交换器和路由键、队列) 一、 channel 信道:   概念:信道是生产消费者与rabbit通信的渠道,生产者publish或是消费者subscribe一个队列都是通过信道来通信的。信道是建立在TCP连接上的虚拟连接,什么意思呢?就是说rabbitmq在一条TCP上建立成百上千个信道

  • RabbitMq中的队列transient和durable的区别2022-07-28 15:04:39

    Durablity:持久化选项 durable:持久化保存。在RabbitMq宕机或者重启后,未被消费的消息仍然存在。可理解为硬盘,关机了但文件还在。 transient:即使保存。在RabbitMq宕机或者重启后交换机会不存在。可理解为计算机内存,关机就没了。

  • rabbitmq权限控制2022-07-27 18:31:56

    两级权限控制 RabbitMQ 授权模型分两级: 第一级控权单位是 virtual host, 第二级控权单位是 resource(包含exchange和queue),两个相同名称的 resource如果分属不同的 virtual host,则算是不同的 resource。 当用户访问 RabbitMQ 时,首先触发第一级控权,判断用户是否有访问该 virtual hos

  • python RabbitMQ+RPC调用传输图片2022-07-27 14:31:46

          整理下用RabbitMQ在client和Server之间用RPC调用传输图片的笔记   RPC:是远程过程调用。百度写了一大堆。此刻,我们简单点说:比如,我们在本地的代码中调用一个函数,那么这个函数不一定有返回值,但一定有返回。若是在分布式环境中,香我们前几章的例子,发送消息出去后,发送端是

  • openstack-rabbitmq2022-07-27 12:32:20

    搭建rabbitmq服务1.准备3台服务器,同步好时钟、关闭selinux和防火墙,配置/etc/hosts文件2.安装epel-release、erlang、rabbitmq-server  [[email protected] ~]# rpm -ivh https://mirrors.aliyun.com/ceph/rpm-mimic/el7/noarch/ceph-release-1-1.el7.noarch.rpm  [[email protected] ~]# yum

  • 通过rabbitMQ发送\Mysql微服务调用链路数据启动zipkin命令2022-07-26 21:36:04

    java -jar zipkin.jar --zipkin.collector.rabbitmq.addressed=localhost   java -jar zipkin.jar --zipkin.torage.type=mysql --zipkin.torage.mysql.host=localhost --zipkin.torage.mysql.port=3306 --zipkin.torage.mysql.username=root --zipkin.torage.mysql.passwor

  • NetCore RabbitMQ Topics 通配符模式2022-07-25 11:00:47

    十年河东,十年河西,莫欺少年穷 学无止境,精益求精 上一节介绍了RabbitMQ定向模式,本篇介绍 Topics 通配符模式 我的系列博客: NetCore RabbitMQ ,Routing定向模式 NetCore RabbitMQ 发布订阅模式,消息广播 RabbitMQ的六种工作模式 NetCore RabbitMQ 简介及兔子生产者、消费者 【简单模式,w

  • RabbitMQ细说之开篇2022-07-24 01:00:31

    前言 关于消息中间件的应用场景,小伙伴们应该都耳熟能详了吧,比如经常提到的削峰填谷、分布式事务、异步业务处理、大数据分析等等,分布式消息队列成为其中比较关键的桥梁,也就意味着小伙伴们得掌握相关技能;当下相对比较热门的消息中间件有RabbitMQ、Kafaka、RocketMQ、ActiveMQ等,在实

  • 消息队列MQ2022-07-23 23:31:15

    一、消息队列概述 MQ(Message Queue)消息队列,是基础数据结构中“先进先出”的一种数据结构。指把要传输的数据(消息)放在队列中,用队列机制来实现消息传递——生产者产生消息并把消息放入队列,然后由消费者去处理。消费者可以到指定队列拉取消息,或者订阅相应的队列,由MQ服务端给其推送消

  • ActiveMQ、RabbitMQ、RocketMQ、Kafka四种消息中间件分析介绍2022-07-23 22:31:49

    ActiveMQ、RabbitMQ、RocketMQ、Kafka四种消息中间件分析介绍 我们从四种消息中间件的介绍到基本使用,以及高可用,消息重复性,消息丢失,消息顺序性能方面进行分析介绍! 一、消息中间件的使用场景 消息中间件的使用场景总结就是六个字:解耦、异步、削峰 1.解耦 如果我方系统A要与三方B系

  • RabbitMQ学习笔记2022-07-23 14:34:57

    RabbitMQ学习笔记 1、添加用户,进行登录 创建账号  rabbitmqctl add_user 用户名 密码 设置用户角色  rabbitmqctl set_user_tags 用户名 角色 设置用户权限  rabbitmqctl set_permissions [-p <vhostpath>] <user> <conf> <write> <read>  # 例如 rabbitmqctl set_per

  • 16、如何保证消息的顺序性2022-07-23 10:04:57

    先看顺序会错乱的场景:RabbitMQ,一个queue,多个consumer,这不明显乱了; 解决: 1、拆分多个queue,每个queue一个consumer,就是多一些queue而已,确实有点麻烦, 2、或者就一个queue就是对应一个consumer,然后这个consumer内部调用内存队列做排队,然后分发给底层不同的worker来处理。

  • 15、Rabbitmq如何保证消息的可靠传输?如果消息丢了怎么办2022-07-23 09:34:34

    数据的丢失问题,可能出现在生产者、MQ、消费者中生产者丢失:生产者将数据发送到 RabbitMQ 的时候,可能数据就在半路给搞丢了,因为网络问题啥的,都有可能。此时可以选择用RabbitMQ 提供的事务功能,就是生产者发送数据之前开启 RabbitMQ事务channel.txSelect,然后发送消息,如果消息没有成功

  • NetCore RabbitMQ ,Routing定向模式2022-07-22 18:14:53

    十年河东,十年河西,莫欺少年穷 学无止境,精益求精 上篇博客介绍了RabbitMQ的六种工作模式 RabbitMQ的六种工作模式  RabbitMQ的简单模式和Work工作模式请参考:NetCore RabbitMQ 简介及兔子生产者、消费者 【简单模式,work工作模式,竞争消费】 RabbitMQ发布订阅模式之消息广播请参考:Net

  • NetCore RabbitMQ 发布订阅模式,消息广播2022-07-22 16:32:44

    十年河东,十年河西,莫欺少年穷 学无止境,精益求精 上篇博客介绍了RabbitMQ的六种工作模式 RabbitMQ的六种工作模式  RabbitMQ的简单模式和Work工作模式请参考:NetCore RabbitMQ 简介及兔子生产者、消费者 【简单模式,work工作模式,竞争消费】 本篇博客使用NetCore完成RabbitMQ发布订阅

  • NetCore RabbitMQ 简介及兔子生产者2022-07-21 18:04:04

    十年河东,十年河西,莫欺少年穷 学无止境,精益求精 先盗用一张图,介绍下RabbitMQ的架构图 简介  Producer : 生产者  channel : 通信信道,节约Tcp链接资源  Broker : MQ Server接点,做集群用的  VirtualHost : 虚拟机,一个RabbitMQ中可以有多个虚拟机,我们可以通过RabbitMQ提供的可视化网

  • Windows10下 安装使用RabbitMQ遇到的特别报错以及各种试错解决方案2022-07-21 15:03:07

     软件环境 Windows10 家庭版 Erlang 版本24.0 RabbitMQServer 3.8.19     安装方式网上随意可以搜到 比如: https://blog.csdn.net/weixin_43876186/article/details/108344733     总体步骤为: 安装Erlang  配置Erlang系统环境变量 并 添加到path中 验证是否安装成

  • RabbitMQ消费者消失与 java OOM2022-07-19 15:01:07

    原因: 下午先是收到钉钉告警有一个消费者系统任务积压, 当时以为就是有范围上量没有当回事,后来客服群开始反馈说有客户的数据没有生成。这个时候查看mq的后台,发现任务堆积数量还是很多。 这个时候登录一台消费者系统查看日志,发现OOM [2022-07-09 16:40:34.640] [ERROR] [org.spring

  • docker安装rabbitMQ以及web stomp插件2022-07-19 12:36:52

    前提是已经安装好docker,那么直接执行下面的命令,即可开启服务。   一  运行一个基础的rabbitmq容器,注意,这里使用这个基础容器,进行插件安装后,生成我们自己带有插件的容器,供后续使用.为方便测试,这里使用带  management 的镜像   docker run -d --hostname rabbit --name=rabbit

  • rabbitMQ--死信队列2022-07-19 11:06:01

      基于消费者 reject requeue设置为false 消息进入死信队列 # 应用名称 spring.application.name=rabbitmq # 应用服务 WEB 访问端口 server.port=8080 spring.rabbitmq.host=192.168.1.137 spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.pass

  • rabbitMQ-死信队列2022-07-19 00:03:30

        reject nack requeue set false 就会成为死信队列消息被消费者拒绝 requeue设置为false消费者拿到消息后 并没有正常执行 执行了nack或者reject 在默认情况下 这个消息会被重新放到队列中给其他消费者再次消费但是如果开启了 requeue=false 那么这个消息就不会

专注分享技术,共同学习,共同进步。侵权联系[admin#icode9.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有