RabbitMq基本使用

时间:2023-03-09 21:53:32
RabbitMq基本使用

  1.新建一个vhost :

  rabbitmqctl add_vhost test

  2.新建一个用户:

  rabbitmqctl add_user news news

  3.对这个news用户增加test host的权限:

  rabbitmqctl set_permissions -p test news ".*" ".*" ".*"

  4.代码中进行连接:

  

   conn, err :=amqp.Dial("amqp://news:news@127.0.0.1:5672/test")
Ch, err = conn.Channel()
//申明队列
Queue, err = Ch.QueueDeclare(
"bigdata",
false,
false,
false,
false,
nil,
)
//发布消息
err := Ch.Publish(
"",
Queue.Name,
false,
false,
amqp.Publishing{
Body: b,
})

  5.查看消息队列中的消息:

  rabbitmqctl list_queues -p bigdataSync