diff --git a/dao/mq/rabbitmq.go b/dao/mq/rabbitmq.go index be242e4b49bf00b6d4aa38875c89dc047acb639b..95ca9c679a9effa12933fc6c7b606d3f11eddfb3 100755 --- a/dao/mq/rabbitmq.go +++ b/dao/mq/rabbitmq.go @@ -8,6 +8,9 @@ import ( var mqUrl = "amqp://admin:Dbc_rabbit_mq123@39.97.234.228:5682/" +//var dbname = "im" +var dbname = "imonline" + // 除了simple 模å¼å¤–ã€å…¶ä»–的模å¼éƒ½æ˜¯ç”± 队列 äº¤æ¢æœº key ä¸åŒç»„åˆå®žçŽ°çš„ type RabbitMQ struct { conn *amqp.Connection @@ -19,9 +22,9 @@ type RabbitMQ struct { } // 创建RabbitMQ 实例 -func newRabbitMQ(queueName, exchange, key string) (*RabbitMQ, error) { +func newRabbitMQ(exchange, key string) (*RabbitMQ, error) { rabbitMQ := &RabbitMQ{ - QueueName: queueName, + QueueName: dbname, Exchange: exchange, Key: key, MQUrl: mqUrl, diff --git a/dao/mq/simple.go b/dao/mq/simple.go index 6ed0059a9c09f5955fcef512b9823dc1c4322425..97c4172357e064b035624c8a7bce00f0ccf92a1d 100755 --- a/dao/mq/simple.go +++ b/dao/mq/simple.go @@ -29,9 +29,9 @@ func (r *RabbitMQ) PublishSimple(message []byte) { } // Step 1. Simple 创建实例 -func NewRabbitMQSimple(queueName string) *RabbitMQ { +func NewRabbitMQSimple() *RabbitMQ { //在simple模å¼ä¸‹ exchange and key 都为空 - rabbitMQ, err := newRabbitMQ(queueName, "", "") + rabbitMQ, err := newRabbitMQ( "", "") if err != nil { fmt.Println("NewRabbitMQSimple err:", err) return nil diff --git a/dao/redis/redis.go b/dao/redis/redis.go index 6436ed7c343ace77d78d374362d3716889929d24..5f6f3d900e323b65974199e870d483f5355fd4eb 100755 --- a/dao/redis/redis.go +++ b/dao/redis/redis.go @@ -6,7 +6,8 @@ import ( ) const ( - host = "39.96.85.45" + //host = "39.96.85.45" + host = "39.97.179.15" port = 6382 password = "saas123456" db = 6 diff --git a/ws_server.go b/ws_server.go index af72baa0f489d270705bb7028064f50c4004ddbc..3e3556089f151a4f09ab436d36ae4861d02285e7 100755 --- a/ws_server.go +++ b/ws_server.go @@ -30,7 +30,7 @@ func main() { flag.Parse() - pool.RabbitMQ = mq.NewRabbitMQSimple("im") + pool.RabbitMQ = mq.NewRabbitMQSimple() fmt.Println("rabbitMq start success") pool.Redis = redis.Init()