文件名称：go_rocket_mq:RocketMQ客户端
文件大小：21KB
文件格式：ZIP
更新时间：2024-06-03 14:14:47
Go
go_rocket_mq 转到rocketmq客户端#import导入rocketmq“ github.com/didapinchegit/go_rocket_mq” #example conf：=＆rocketmq.Config {名称服务器：“ 192.168.1.234:9876”，ClientIp：“ 192.168.1.23”，InstanceName：“ DEFAULT”，}消费者，err：= rocketmq.NewDefaultConsumer（“ C_TEST”，conf）如果err！= nil {log.Panic（err）} Consumer.Subscribe（“ test2”，“ ”）Consumer.Subscribe（“ test3”，“ ”）Consumer.RegisterMessageListener（func（msgs [] * rocketmq.
【文件预览】：
go_rocket_mq-master
----request_code.go(6KB)
----rebalance.go(5KB)
----example()
--------main.go(573B)
----message.go(3KB)
----message_queue.go(823B)
----net_test.go(97B)
----remoting_client.go(7KB)
----response_code.go(2KB)
----client_test.go(3KB)
----.idea()
--------vcs.xml(167B)
--------libraries()
----net.go(748B)
----pull_message.go(1KB)
----.gitignore(19B)
----consumer.go(8KB)
----remote_cmd.go(2KB)
----README.md(580B)
----admin.go(424B)
----mqclient.go(12KB)
----store.go(4KB)