创建连接及RabbitMQ结构体实例代码见 https://www.cnblogs.com/prince5460/p/11895844.html1.创建话题模式RabbitMQ实例func NewRabbitMQTopic(exchangeName, routingKey string) *RabbitMQ {//创建RabbitMQ实例rabbitmq := NewRabbitMQ("", exchangeName, routingKey)var err error//获取connectionrabbitmq.conn, err = amqp.Dial(rabbitmq.Mqurl)rabbitmq.failOnErr(err, "Failed to connect rabbitmq!")//获取channelrabbitmq.c...
在上一篇moonmq的介绍中（这里），我只简短的罗列了一些moonmq的设计想法，可是对于怎样使用并没有具体说明，公司同事无法非常好的使用。 对于moonmq的使用，事实上非常easy，例子代码在这里，我们仅仅须要处理好broker，consumer以及publisher的关系就能够了。 首先，我们须要启动一个broker，由于moonmq如今仅仅支持tcp的自己定义协议，所以broker启动的时候须要指定一个listen address。#启动broker ./simple_broker -addr=127...
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...
golang 操作 Redis & Mysql & RabbitMQ 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...
package mainimport ("fmt""time""github.com/garyburd/redigo/redis" )const (RedisURL = "redis://127.0.0.1:6379"redisMaxIdle = 3 //最大空闲连接数redisIdleTimeoutSec = 240 //最大空闲连接时间RedisPassword = "123456" )// NewRedisPool 返回redis连接池 func NewRedisPool(redisURL string) *redis.Pool {return &redis.Pool{MaxIdle: redisMaxIdle,IdleTimeout: redisIdleTimeoutSec * ti...
前言：提到消息队列，首先想到：rabbit、kafka、redis/cordis、zeromq这种分布式的消息队列，基于内存缓存和服务发现算法，跨节点的这种消息发布订阅机制。 有时候的需求可能比较简单，需要一个可以不溢出的本地消息队列，diskqueue就是这种设计目标，基于文件的消息队列。源码目录：total 2630 drwxr-xr-x 1 Administrator 197121 0 4月 8 16:31 diskqueue/ -rw-r--r-- 1 Administrator 197121 59 4月 7 17:42 go....