一、获取镜像
二、运行镜像
?
1
2
3
4
5
三、访问ui页面
http://localhost:15672/
四、golang案例
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
#producer生产者代码
package main
import (
“fmt”
“log”
“github.com/streadway/amqp”
)
const (
//amqp uri
uri = “amqp://guest:guest@10.0.0.11:5672/” // 10.0.0.11为主机ip
//durable amqp exchange name
exchangename = “”
//durable amqp queue name
queuename = “test-queues”
//body of message
bodymsg string = “hello angel”
)
//如果存在错误，则输出
func failonerror(err error, msg string) {
if err != nil {
log.fatalf(“%s: %s”, msg, err)
panic(fmt.sprintf(“%s: %s”, msg, err))
}
}
func main() {
//调用发布消息函数
publish(uri, exchangename, queuename, bodymsg)
log.printf(“published %db ok”, len(bodymsg))
}
//发布者的方法
//@amqpuri, amqp的地址
//@exchange, exchange的名称
//@queue, queue的名称
//@body, 主体内容
func publish(amqpuri string, exchange string, queue string, body string) {
//建立连接
log.printf(“dialing %q”, amqpuri)
connection, err := amqp.dial(amqpuri)
failonerror(err, “failed to connect to rabbitmq”)
defer connection.close()
//创建一个channel
log.printf(“got connection, getting channel”)
channel, err := connection.channel()
failonerror(err, “failed to open a channel”)
defer channel.close()
log.printf(“got queue, declaring %q”, queue)
//创建一个queue
q, err := channel.queuedeclare(
queuename, // name
false, // durable
false, // delete when unused
false, // exclusive
false, // no-wait
nil, // arguments
)
failonerror(err, “failed to declare a queue”)
log.printf(“declared queue, publishing %db body (%q)”, len(body), body)
// producer只能发送到exchange，它是不能直接发送到queue的
// 现在我们使用默认的exchange（名字是空字符）这个默认的exchange允许我们发送给指定的queue
// routing_key就是指定的queue名字
err = channel.publish(
exchange, // exchange
q.name, // routing key
false, // mandatory
false, // immediate
amqp.publishing{
headers: amqp.table{},
contenttype: “text/plain”,
contentencoding: “”,
body: []byte(body),
})
failonerror(err, “failed to publish a message”)
}
五、拥有消息确认的代码
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
#producer
package main
import (
“fmt”
“github.com/streadway/amqp”
“log”
“os”
“strings”
)
const (
//amqp uri
uri = “amqp://guest:guest@10.0.0.11:5672/”
//durable amqp exchange name
exchangename = “”
//durable amqp queue name
queuename = “test-queues-acknowledgments”
)
//如果存在错误，则输出
func failonerror(err error, msg string) {
if err != nil {
log.fatalf(“%s: %s”, msg, err)
panic(fmt.sprintf(“%s: %s”, msg, err))
}
}
func main() {
bodymsg := bodyfrom(os.args)
//调用发布消息函数
publish(uri, exchangename, queuename, bodymsg)
log.printf(“published %db ok”, len(bodymsg))
}
func bodyfrom(args []string) string {
var s string
if (len(args) < 2) || os.args[1] == “” {
s = “hello angel”
} else {
s = strings.join(args[1:], ” “)
}
return s
}
//发布者的方法
//@amqpuri, amqp的地址
//@exchange, exchange的名称
//@queue, queue的名称
//@body, 主体内容
func publish(amqpuri string, exchange string, queue string, body string) {
//建立连接
log.printf(“dialing %q”, amqpuri)
connection, err := amqp.dial(amqpuri)
failonerror(err, “failed to connect to rabbitmq”)
defer connection.close()
//创建一个channel
log.printf(“got connection, getting channel”)
channel, err := connection.channel()
failonerror(err, “failed to open a channel”)
defer channel.close()
log.printf(“got queue, declaring %q”, queue)
//创建一个queue
q, err := channel.queuedeclare(
queuename, // name
false, // durable
false, // delete when unused
false, // exclusive
false, // no-wait
nil, // arguments
)
failonerror(err, “failed to declare a queue”)
log.printf(“declared queue, publishing %db body (%q)”, len(body), body)
// producer只能发送到exchange，它是不能直接发送到queue的。
// 现在我们使用默认的exchange（名字是空字符）。这个默认的exchange允许我们发送给指定的queue。
// routing_key就是指定的queue名字。
err = channel.publish(
exchange, // exchange
q.name, // routing key
false, // mandatory
false, // immediate
amqp.publishing{
headers: amqp.table{},
contenttype: “text/plain”,
contentencoding: “”,
body: []byte(body),
})
failonerror(err, “failed to publish a message”)
}
到此这篇关于docker快速安装rabbitmq的方法步骤的文章就介绍到这了,更多相关docker安装rabbitmq内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://www.cnblogs.com/angelyan/p/11218260.html
声明： 猿站网有关资源均来自网络搜集与网友提供，任何涉及商业盈利目的的均不得使用，否则产生的一切后果将由您自己承担！ 本平台资源仅供个人学习交流、测试使用 所有内容请在下载后24小时内删除，制止非法恶意传播，不对任何下载或转载者造成的危害负任何法律责任！也请大家支持、购置正版！ 。本站一律禁止以任何方式发布或转载任何违法的相关信息访客发现请向站长举报，会员发帖仅代表会员个人观点，并不代表本站赞同其观点和对其真实性负责。本网站的资源部分来源于网络，如有侵权烦请发送邮件至：2697268773@qq.com进行处理。