RabbitMQ 学习记录

rabbit mq知识点：
1.消费时可以通过acknowledge设定消费是否成功，消费不成功时在server端requeue
2.需要注意两个持久化：queue持久化和消息持久化(通过代码设定，默认即时开启持久化，消息有一定丢失可能)
3.可以在一个connection上并发运行多个channel

rabbit mq问题：

1.现在消费者是按条消费的，如何改成按批次消费

2.多消费者时采取轮询模式，例如有两个消费者AB分配5个任务，则A分配到0、2、4，B分配到1、3 ，此时如果A执行0任务时阻塞，则任务2、4将一直等待 且0、2、4任务在服务器端认为已被A消费（解决方案：使用channel.basicQos(prefetchCount)  设定客户端每次从服务器拉取数据的条数）

时间： 2024-07-30 13:36:10

RabbitMQ 学习记录的相关文章

rabbitmq 学习记录 -- 基本概念

派猴子来的救兵 messag queue嘛, 就是生产者往里扔东西, 消费者取走. 但是要涉及到细节,还是有些多的. 基本概念 其实就是官网文档的搬运工. 路由模型 先来看看一条消息的生命线, 生产者把消息发送到exchange, 然后根据exchange的类型和routing key(消息发送时的一个参数), 把这条消息路由到不同的队列中去, 图片中是发到了一个列队, 其实也可以到多个. 然后消费都从队列中把消息取走. 和kafka有些不同, rabbitmq里面的一个队列里面一条消息被一个消

RabbitMQ学习记录1

前言 我是在解决分布式事务的一致性问题时了解到RabbitMQ的,当时主要是要基于RabbitMQ来实现我们分布式系统之间对有事务可靠性要求的系统间通信的.关于分布式事务一致性问题及其常见的解决方案,可以看我另一篇博客.提到RabbitMQ,不难想到的几个关键字:消息中间件.消息队列.而消息队列不由让我想到,当时在大学学习操作系统这门课,消息队列不难想到生产者消费者模式.(PS:操作系统这门课程真的很好也很重要,其中的一些思想在我工作的很长一段一时间内给了我很大帮助和启发,给我提供了许多解决问题

rabbitmq 学习记录 -- ACK和数据持久化

派猴子来的救兵 为了数据不丢失, 需要在两个层面上做一些配置. 一个是ACK, 一个是数据持久化. ACK 如果没有启用的话, 消费者拿走消息的时候, queue就把它删除了. 消费者拿走一条消息之后, 还没有处理完就crash了. 那么这条消息就丢失了. 为了保证消息一定被处理完了才从queue中被删掉, 就要启用Message acknowledgment . 启用之后, queue会在收到ack之后把消息删掉. 在这里没有timeout的概念, 哪怕这个任务执行很久, 不管多久, 会一直等

rabbitmq 学习记录 -- TTL

派猴子来的救兵 queue本身的TTL 注意, 这里说的是queue本身的TTL. 不是说里面的消息 声明一个队列的时候, 可以用x-expires指定队列的TTL值. 过期之后, 这个队列就被删掉了. 不管里面是不是还有消息没有消费 #!/usr/bin/env python # -*- coding: utf-8 -*- ''' the queue exists for only 5 seconds, whether there is messages! ''' import pika im

Python学习记录-2016-12-17

今日学习记录 模块: import os#导入os模块 import sys#导入sys模块 os.system("df -h")#执行df -h命令 cmd_res = os.popen("df -h").read()#将命令的返回结果赋值给cmd_res,如果不加入.read()会显示命令的返回加过在内存的位置 print(sys.path)#显示系统变量路径,一般个人模块位于site-packages下,系统模块位于lib下 print(sys.argu[2]

Objc基础学习记录5

NSMutableString类继承的NSString类. NSMutableString是动态的字符串. 1.appendingString 方式: 向字符串尾部添加一个字符串. 2.appendingFormat:可以添加多个类型的字符串. int,chat float,double等 3.stringWithString 创建字符串, 4.rangeOfString 返回str1在另一个字符串中的位置. 5.NSMakeRange(0,3) 字符串0位到3位. 6.deleteCharac

Windows API 编程学习记录<二>

恩,开始写Windows API编程第二节吧. 上次介绍了几个关于Windows API编程最基本的概念,但是如果只是看这些概念,估计还是对Windows API不是很了解.这节我们就使用Windows API 让大家来了解下Windows API的用法. 第一个介绍的Windows API 当然是最经典的MessageBox,这个API 的作用就是在电脑上显示一个对话框,我们先来看看这个API的定义吧: int WINAPI MessageBox(HWND hWnd, LPCTSTR lpTe

Windows API 编程学习记录<三>

恩,开始写API编程的第三节,其实马上要考试了,但是不把这节写完,心里总感觉不舒服啊.写完赶紧去复习啊       在前两节中,我们介绍了Windows API 编程的一些基本概念和一个最基本API函数 MessageBox的使用,在这节中,我们就来正式编写一个Windows的窗口程序. 在具体编写代码之前,我们必须先要了解一下API 编写窗口程序具体的三个基本步骤:             1. 注册窗口类:             2.创建窗口:             3.显示窗口: 恩,

Python学习记录day6

Python学习记录day6 学习 python Python学习记录day6 1.反射 2.常用模块 2.1 sys 2.2 os 2.3 hashlib 2.3 re 1.反射 反射:利用字符串的形式去对象(默认)中操作(寻找)成员 cat commons.py #!/usr/bin/env python#_*_coding:utf-8_*_''' * Created on 2016/12/3 21:54. * @author: Chinge_Yang.''' def login(): pr