Reids 安装导入go get github.com/garyburd/redigo/redis import "github.com/garyburd/redigo/redis"链接 github：https://github.com/antirez/redis Doc：http://godoc.org/github.com/garyburd/redigo/redis Redis全套使用：http://www.cnblogs.com/suoning/p/5807247.html 使用 连接import "github.com/garyburd/redigo/redis"func main() {c, err := redis.Dial("tcp", "localhost:6379")if err != nil {fmt.Println("conn re...
一：安装RabbitMQ需要先安装Erlang语言开发包，百度网盘地址：http://pan.baidu.com/s/1jH8S2u6。直接下载地址：http://erlang.org/download/otp_win64_18.3.exe。 安装完成后需要配置环境变量： 新建系统变量：变量名 ERLANG_HOME 变量值 D:\softInstall\erl8.3（Erlang安装目录） 添加到PATH：%ERLANG_HOME%\bin; 二：安装RabbitMQ Server，百度网盘地址：http://pan.baidu.com/s/1eRLlSrg。直接下载地址：http://www.rabbitmq.c...
文章目录一、RocketMQ 生产者源码分析1.启动过程2.消息发送过程二、Kafka 消费者源码分析1.订阅过程2.拉取消息一、RocketMQ 生产者源码分析 版本 release-4.5.1 客户端是一个单独的 Module，在 rocketmq/client 目录中。 源码分析，可以从测试用例入手，一步一步跟踪其方法调用链路，理清实现过程。 Producer 的所有测试用例都在同一个测试类中org.apache.rocketmq.client.producer.DefaultMQProducerTest 这个测试类的主要测试方法...
消息队列的消息重复消费 消息重复消费是使用消息队列之后，必须考虑的一个问题，也是比较严重和常见的问题。比如有这样的一个场景，用户下单成功后我需要去一个活动页面给他加GMV（销售总额），最后根据他的GMV去给他发奖励，这是电商活动很常见的玩法。 类似累计下单金额到哪个梯度给你返回什么梯度的奖励这样。我只能告诉你这样的活动页面100%是用异步去加的，不然一个用户下一单就给他加一下，那就意味着对那张表就要操作一下，...