消息队列的基本原理 消息队列是基于队列实现的，存储具有特定格式的消息数据。消息队列包括生产者，消息队列以及消费者。 RocketMQ的原理与工作机制 架构图 NameServer Cluster：名字服务器集群，类似于kafka中的zookeeper，提供分布式协调与管理的功能 Producer C ...
分类：
其他好文 时间：
2020-02-15 11:46:33
阅读次数：
63
/** * RabbitMQ消息确认机制 * 关于rabbit的生产和消费方的一些实用的操作； * producer的confirm和consumer的ack，这两者使用的模式都是用来保证数据完整性，防止数据丢失 */ /** * producer的confirm模式 * 业务场景描述： * 促销系 ...
分类：
其他好文 时间：
2020-02-14 11:14:24
阅读次数：
98
〇、rabbitMQ官方文档 https://www.rabbitmq.com/tutorials/tutorial-one-python.html 一、RabbitMQ 原理简介 1. RabbitMQ 角色 生产者：消息的创建者，负责创建和推送数据到消息服务器； 消费者：消息的接收方，用于处理数 ...
分类：
其他好文 时间：
2020-02-11 11:52:56
阅读次数：
70
"offset" "topic" "consumer group" "consumer" "producer" "producer golang" topic 工具 "https://cwiki.apache.org/confluence/display/KAFKA/Replication+tool ...
分类：
其他好文 时间：
2020-02-09 18:42:32
阅读次数：
243
增加了buffsize，生产者生产过多，wait #include <stdio.h> #include <unistd.h> #include <pthread.h> #define PRODUCER_SIZE 1 #define CONSUMER_SIZE 1 int products = 0; ...
分类：
其他好文 时间：
2020-02-09 16:28:51
阅读次数：
66
package com.itheima.cglib;import com.itheima.proxy.IProducer;import com.itheima.proxy.Producer;import com.sun.webkit.dom.ProcessingInstructionImpl;imp ...
分类：
其他好文 时间：
2020-02-08 00:44:32
阅读次数：
65
一、两阶段提交 2PC 1、数据库层面的两阶段提交(XA trainsaction) 两阶段提交是目前经常使用的一种解决分布式事物的强一致性的一种方案，它是由事物协调器和若干个事物执行者（数据库本身）组成。 所谓两阶段提交就是将每一个事物拆分成 任务+提交，将任务的执行和任务提交分成两步。当客户端发 ...
分类：
其他好文 时间：
2020-02-05 18:51:42
阅读次数：
68
迭代器出现的原因 Python中的列表，有可能会占用很大的空间。而迭代器，它是每一次用__next__调用时才计算出值，这会节省内存空间。 迭代器、生成器、可迭代对象的关系 可迭代对象一般是列表、元组、字典、字符串等可以For循环的对象。可通过以下语句判断是不是可迭代对象。 from collect ...
分类：
其他好文 时间：
2020-02-01 10:53:01
阅读次数：
64
一、项目结构 项目结构如何 两个模块，一个为消费方，一个为提供方，也可将两个模块合一，配置文件合一。 二、整合步骤 一、pom.xml 生产方、消费方一致 二、Producer模块 测试代码： 三、Consumer模块 1.配置文件 2.监听器 分别监听提供方queue和topic的消息 启动消费方 ...
分类：
编程语言 时间：
2020-01-30 20:54:55
阅读次数：
101
producer 在发送消息的时候，会生成一个 "唯一" 的 msgId，broker 会为这个 msgId 创建哈希索引 UNIQ_KEY 由客户端生成 org.apache.rocketmq.common.message.MessageClientIDSetter#createUniqID ms ...
分类：
其他好文 时间：
2020-01-30 14:40:40
阅读次数：
103
