Rabbitmq和Kafka简单的性能测试

　　rabbitmq:
package main
import (
"github.com/streadway/amqp"
"time"
"fmt"
"log"
)
const (
queueName = "push.msg.q"
exchange  = "t.msg.ex"
mqurl ="amqp://shimeng:shimeng1015@192.168.155.106:5672/push"
)
var conn *amqp.Connection
var channel *amqp.Channel
func main() {
fmt.Println(1)
//    push()
receive()
//    fmt.Println("end")
//    close()
}
func failOnErr(err error， msg string) {
if err != nil {
log.Fatalf("%s:%s"， msg， err)
panic(fmt.Sprintf("%s:%s"， msg， err))
}
}
func mqConnect() {
var err error
conn， err = amqp.Dial(mqurl)
if err != nil {
log.Println(1)
log.Fatalln(err)
}
fmt.Println(5)
channel， err = conn.Channel()
if err != nil {
fmt.Println(2)
log.Fatalln(err)
}else {
fmt.Println("a")
}
}
func push() {
count := 0
if channel == nil {
fmt.Println(2)
mqConnect()
}else {
fmt.Println(3)
}
msgContent := "hello world!"
t1 := time.NewTicker(time.Second)
go func() {
for{
<- t1.C
log.Println(count)
}
}()
for{
err := channel.Publish(exchange， "test"， false， false， amqp.Publishing{
ContentType: "text/plain"，
Body:        []byte(msgContent)，
})
if err != nil {
}else {
count ++
}
}
}
func receive() {
if channel == nil {
mqConnect()
}
count :=0
msgs， err := channel.Consume(queueName， ""， true， false， false， false， nil)
failOnErr(err， "")
forever := make(chan bool)
t1 := time.NewTicker(time.Second)
go func() {
for{
<- t1.C
log.Println(count)
}
}()
go func() {
//fmt.Println(*msgs)
for _= range msgs {
count ++
//            s := BytesToString(&(d.Body))
//            count++
//            fmt.Printf("receve msg is :%s -- %d "， *s， count)
}
}()
fmt.Printf(" [*] Waiting for messages. To exit press CTRL+C ")
<-forever
}