golang与activeMQ

package main

import stomp "github.com/go-stomp/stomp"
import "fmt"

//Connect to ActiveMQ and listen for messages
func main() {
conn, err := stomp.Dial("tcp", "localhost:61613")
if err != nil {
fmt.Println(err)
}

sub, err := conn.Subscribe("/queue/test-1", stomp.AckAuto)
if err != nil {
fmt.Println(err)
}
for {
msg := <-sub.C
fmt.Println(msg)
}

err = sub.Unsubscribe()
if err != nil {
fmt.Println(err)
}
defer conn.Disconnect()
}

---

package main

import stomp "github.com/go-stomp/stomp"
import "fmt"

//Connect to ActiveMQ and produce messages
func main() {
conn, err := stomp.Dial("tcp", "localhost:61613")
if err != nil {
fmt.Println(err)
}

c := make(chan string)
quit := make(chan string)
go Producer(c, quit, conn)

for {
fmt.Println(<-c)
}
quit<-"read"
}

func Producer(c, quit chan string, conn *stomp.Conn) {
for {
select {
case c <- "msg sent":
err := conn.Send(
"/queue/test-1", // destination
"text/plain", // content-type
[]byte("Test message #1")) // body
if err != nil {
fmt.Println(err)
return;
}
case <-quit:
fmt.Println("finish")
return;
}
}
}

go run main.go
Run Consumer:

go run reader.go

通过网页可以查看到，消息有生产，也有消费。

​​推荐​​

【文章原创作者：防ddos攻击 http://www.558idc.com/shsgf.html 复制请保留原URL】