4
package main
import (
"fmt"
"github.com/streadway/amqp"
"time"
)
// Every connection should declare the topology they expect
func setup(url, queue string) (*amqp.Connection, *amqp.Channel, error) {
//setup connection
conn, err := amqp.Dial(url)
if err != nil {
return nil, nil, err
}
//build channel in the connection
ch, err := conn.Channel()
if err != nil {
return nil, nil, err
}
//queue declare
if _, err := ch.QueueDeclare(queue, false, true, false, false, nil); err != nil {
return nil, nil, err
}
return conn, ch, nil
}
func main() {
//amqp url
url := "amqp://guest:[email protected]:5672";
for i := 1; i <= 2; i++ {
fmt.Println("connect ", i)
//two goroutine
go func() {
//queue name
queue := fmt.Sprintf("example.reconnect.%d", i)
//setup channel in the tcp connection
_, pub, err := setup(url, queue)
if err != nil {
fmt.Println("err publisher setup:", err)
return
}
// Purge the queue from the publisher side to establish initial state
if _, err := pub.QueuePurge(queue, false); err != nil {
fmt.Println("err purge:", err)
return
}
//publish msg
if err := pub.Publish("", queue, false, false, amqp.Publishing{
Body: []byte(fmt.Sprintf("%d", i)),
}); err != nil {
fmt.Println("err publish:", err)
return
}
//keep running
for{
time.Sleep(time.Second * 20)
}
}()
}
//keep running
for {
time.Sleep(time.Second * 20)
}
}
我想只有一个程序和MQ-服务器之间的连接,一个连接可以在rabbitmq的go api中支持多个通道吗?
但有两个方面,一个连接只能支持一个通道,为什么呢?
不能这两个goroutine共享相同的tcp连接吗?
套接字描述符可以共享理论中的所有进程线程。
为什么两个goroutine不共享一个套接字但有自己的通道?
手工模型:
在RabbitMQ的真实模型:
一个连接。两个连接,如果在两个goroutine.I不知道为什么? @DavidB – 2014-10-15 19:30:21
它看起来像连接和通道是线程安全的,你确定你不能使用来自多个goroutines的连接? (再一次,我没有亲自尝试过) – 2014-10-16 01:33:36
我想表达的是,有多少个goroutines调用了amqp.Dial()来决定tcp连接的数量,主要我想知道的是为什么这样设计?例如只有主线程调用amqp.Dial(),所以有1个tcp连接。我的例子中有2个线程调用amqp.Dial(),所以有2个tcp连接。很抱歉,我没有表达我的问题清楚吗?但是您的示例显示频道可以共享一个连接。 @DavidB – 2014-10-16 11:25:42