这是测试生产者
**代码**
```
func Send(queueName string, msg interface{}) error {
if ch == nil {
if err := InitRabbitmq(Url); err != nil {
log.Println(err)
return err
}
}
_, err := ch.QueueDeclarePassive(queueName, true, false, false, true, nil)
if err != nil {
q, err = ch.QueueDeclare(queueName, true, false, false, false, nil)
if err != nil {
log.Println(err)
return err
}
}
data, err := json.Marshal(msg)
if err != nil {
return err
}
count++
log.Println(q, count)
err = ch.Publish(queueName,
q.Name,
false,
false,
amqp.Publishing{
ContentType: "application/json",
Body: data,
})
if err != nil {
log.Println(err)
return err
}
return nil
}
```
```
func InitRabbitmq(url string) error {
var (
err error
)
conn, err = amqp.Dial(url)
if err != nil {
log.Println("Failed to connect to RabbitMq")
return err
}
ch, err = conn.Channel()
if err != nil {
defer conn.Close()
log.Println("Failed to open a channel")
return err
}
mqsync.Lock()
defer mqsync.Unlock()
q, err = ch.QueueDeclare("hello_world", true, false, false, false, nil)
if err != nil {
log.Println("Failed to declare queue:", err.Error())
return err
}
log.Println("rabbitmq init ok!")
return nil
}
```
```
var Url = `amqp://guest:guest@0.0.0.0:5672/`
func main(){
log.SetFlags(log.Lshortfile)
err := InitRabbitmq(Url)
if err != nil {
log.Println(err)
}
go func(){
data :=map[string]interface{}{
"1":hello,
}
for {
err := Send(data)
if err != nil {
log.Println(err)
}
time.Sleep(1 * time.Second)
}
}
go func(){
data :=map[string]interface{}{
"2":world,
}
for {
err := Send(data)
if err != nil {
log.Println(err)
}
time.Sleep(1 * time.Second)
}
}
select {}
}
```
**问题：**
**错误信息**
**分析**
>测试发现不是消费者好着，通过再次启动此程序发现
询问还有其他问题影响吗？
有疑问加站长微信联系（非本文作者）
