ICode9

精准搜索请尝试: 精确搜索
  • docker-compose安装RabbitMQ2022-06-12 00:33:24

    RabbitMQ Compose 配置文件 点击查看代码 version: '3.9' services: rabbitmq: image: rabbitmq:3.9-management restart: always container_name: rabbitmq3.9 hostname: rabbitmq3.9 privileged: true ports: - 5672:5672 - 15

  • 使用docker快速构建RabbitMQ2022-06-10 20:08:09

      有时间,我们需要rabbitmq测试一下,如果按照原方案部署一个rabbitmq,比较麻烦,这个时候可以使用docker快速构建一个rabbitmq来使用。   rabbitmq:management (推荐)   我们可以通过官方的镜像rabbitmq:management来实现,如果是直接使用命令行: # 拉取镜像 sudo docker pull

  • Linux 镜像安装MQ 、集群部署等2022-06-09 18:33:13

    1.单机部署 我们在Centos7虚拟机中使用Docker来安装。 1.1.下载镜像 方式一:在线拉取 docker pull rabbitmq:3.8-management   方式二:从本地加载 在课前资料已经提供了镜像包:       上传到虚拟机中后,使用命令加载镜像即可: docker load -i mq.tar     1.2.安装MQ 执行下

  • go使用rabbitmq2022-06-09 18:03:16

    rabbitmq是一款消息中间件,采用erlang语言编写。基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、安全。AMQP协议更多用在企业系统内,对数据一致性、稳定性和可靠性要求很高的场景,对性能和吞吐量的要求还在其次。消息的消费者被动拉取(rabb

  • RabbitMq基础二之direct模式2022-06-09 17:31:36

    生产者:product.php $conConfig = [ 'host' => '127.0.0.1', 'port' => '5672', 'login' => 'sblack', 'password' => '123456', 'vhost' => '/'

  • rabbitmq 工作模式2022-06-09 14:34:18

    package main import ( "fmt" "github.com/streadway/amqp" "log" "time" ) func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) } } func x

  • 【RabbitMQ 笔记】— 方法解读2022-06-09 13:35:07

    通过上一篇【RabbitMQ 笔记】— 基本概念,知道生产者和消费者使用到的主要类和接口有 ConnectionFactory、Connection、Channel、Consumer 等。Connection 是用来开启 Channel 的,RabbitMQ 开发工作也基本上是围绕 Connection 和 Channel 这两个类展开。 连接 RabbitMQ 多线程共享

  • 【RabbitMQ 笔记】— 死信队列2022-06-09 13:33:54

    死信交换器,Dead Letter Exchange,下文简称 DLX。当消息在一个队列中变成死信(Dead Letter)之后,它会被发送到另一个交换器中,这个交换器就是 DLX,绑定 DLX 的队列就称为死信队列。 消息变成死信一般由以下几种情况: 消息被拒绝(Basic.Reject / Basic.Nack),并且设置 requeue 参数为 false

  • Linux RabbitMQ 安装2022-06-08 20:00:13

    安装 erlang 下载 erlang 安装包 wget http://erlang.org/download/otp_src_24.3.tar.gz 解压 erlang 安装包 tar -xvzf /usr/root/otp_src_24.3.tar.gz 安装 erlang 的依赖工具 yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel unixODBC-de

  • 定时任务实现(RabbitMQ 延迟队列)2022-06-08 15:32:51

    前言 其实rabbit 没有现成可用的延迟队列,但是可以利用其两个重要特性来实现之:1、Time To Live(TTL)消息超时机制;2、Dead Letter Exchanges(DLX)死信队列。   先理解一个概念: rabbit 中一个消息是有死亡状态的,它会被发送到一个指定的队列中,这个队列是一个普通的队列,根据他的功能,我们

  • Windows环境下安装RabbitMQ2022-06-07 23:00:13

    本地安装RabbitMQ安装注意事项: Erlang与RabbitMQ,安装路径都应不含空格符。 Erlang使用了环境变量HOMEDRIVE与HOMEPATH来访问配置文件.erlang.cookie,应注意这两个环境变量的有效性。需要设定环境变量ERLANG_HOME,并把erlang的bin路径复制到全局路径中。 RabbitMQ使用本地computer na

  • 记一次rabbitmq 消息不能接受故障的处理2022-06-07 01:03:10

    问题 当时比较怪异,现象是通过rabbitmq 的management可以发送消息(消息内容比较小,很简单的),但是通过代码没有任何报错 但是消息就是不能看到(management 界面) 排错处理 开始以为是代码处理问题,但是没有异常日志,也怀疑因为代码发布造成队列错误造成消息写入错误,我一般的此类问题的方式

  • 基于MassTransit.RabbitMQ的延时消息队列2022-06-03 19:31:09

    1 nuget包 <PackageReference Include="MassTransit.RabbitMQ" Version="8.0.2" /> 注意事项 本次使用的是docker来运行RabbitMQ 命令是: docker run -d -p 15672:15672 -p 5672:5672 -p 5671:5671 --hostname my-rabbitmq --name my-rabbitmq-container rabbitmq:3

  • golang rabbitmq 简单模式2022-06-02 15:04:04

    package main import ( "fmt" "github.com/streadway/amqp" "log" ) func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) } } func getConn() *amqp.Connec

  • RabbitMQ——工作队列2022-05-31 22:32:22

    RabbitMQ——工作队列 一、任务队列/工作队列 (使用Go RabbitMQ客户端) 我们编写程序从命名的队列发送和接收消息。在这一节中,我们将创建一个工作队列,该队列将用于在多个工人之间分配耗时的任务。 工作队列(又称任务队列)的主要思想是避免立即执行某些资源密集型任务并且不得不等待这

  • springboot整合RabbitMQ入门2022-05-31 01:33:43

    一、配置文件 1.1 pom文件 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <

  • Centos安装RabbitMQ2022-05-30 20:34:03

    手动部署RabbitMQ 1、创建并远程连接Linux实例。 2、安装erlang 1 运行以下命令,安装erlang所需要的依赖 yum install -y make gcc gcc-c++ m4 openssl openssl-devel ncurses-devel unixODBC unixODBC-devel java java-devel 2 运行以下命令,下载erlang安装包 wget http://erla

  • RabbitMQ的工作模式概念详解2022-05-30 14:34:35

    目录一、核心概念二、工作模式2.1 simple简单队列2.2 work工作队列2.3 publish/subscribe发布订阅(共享资源)2.4 路由模式2.5 topic主题模式 一、核心概念 生产者:发送消息的应用程序。 消费者:接收消息的应用程序。 队列:存储消息的缓冲区。 消息:通过RabbitMQ从生产者发送给消费者

  • RabbitMQ2022-05-29 02:32:36

    前言 官方文档 生产者与消费者的解耦分离 使用 连接 import pika RabbitMQHost = 'localhost' conn = pika.BlockingConnection( pika.ConnectionParameters(host=RabbitMQHost) ) channel = conn.channel() conn.close() 简单模式 生产者 # 创建队列 queue_name = 'firs

  • SpringBoot整合RabbitMQ2022-05-28 22:31:44

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

  • RabbitMQ的内存节点和磁盘节点说明2022-05-28 02:02:42

    在RabbitMQ集群中有内存节点和磁盘节点之分 内存节点(ram):就是将元数据都放在内存里,内存节点的话,只要服务重启,该节点的所有数据将会丢失 硬盘节点(disc):就是将元数据都放在硬盘里,所以服务重启的话,数据也还是会存在的,所以像我们的持久化消息、持久化队列等,都会放置硬盘节点保存 在Rabbi

  • RabbitMq基本概念2022-05-27 01:02:03

    目录一、什么是消息队列二、RabbitMQ的优势2.1 应用解耦2.2 异步提速2.3 流量削峰三、MQ的劣势四、RabbitMQ中的相关概念 一、什么是消息队列 MQ全称 Message Queue(消息队列),是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。消息指的是两个应用间传递的数据。

  • SpringBoot 整合 RabbitMQ 实现消息可靠传输2022-05-25 08:01:16

    消息的可靠传输是面试必问的问题之一,保证消息的可靠传输主要在生产端开启 comfirm 模式,RabbitMQ 开启持久化,消费端关闭自动 ack 模式。 环境配置 SpringBoot 整合 RabbitMQ 实现消息的发送。 添加 maven 依赖 <dependency> <groupId>org.springframework.b

  • Centos7.4离线安装RabbitMQ单机服务器2022-05-24 17:32:05

    RabbitMQ离线安装 目录RabbitMQ离线安装一、RabbitMQ离线安装包下载二、离线安装RabbitMQ三、RabbitMQ常用命令四、创建用户操作五、开启web管理界面插件 一、RabbitMQ离线安装包下载 百度云盘链接:https://pan.baidu.com/s/12hllpK695Gscaj_QeQSTNA 提取码:r2g3 二、离线安装Rabb

  • Windows下RabbitMQ安装及配置2022-05-24 09:31:47

      rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统。它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rabbit MQ 是建立在Erlang OTP平台上。 1、安装Erlang 下载地址:https://www.erlang.org/downloads,本文选择OTP 21.

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

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

ICode9版权所有