rabbitmq add user and pass basic:basic

liuxiaolong

2019-11-26 38f6ad1d07fac36879ec5ce45fc5e39d20b335d2

rabbitmq add user and pass basic:basic

 server.go

@@ -26,6 +26,8 @@
var env = flag.String("env", "config", "env set")
var mqIp = flag.String("mqIp", "172.17.50.245", "default mq ip")
var mqPort = flag.Int("mqPort", 5672, "default mq port")
var mqUser = flag.String("mqUser", "basic", "default rabbitmq user")
var mqPass = flag.String("mqPass", "basic", "default rabbitmq pass")

func main() {
    flag.Parse()
@@ -56,8 +58,8 @@
    //    go handleConnection(conn,connArr)
    //}

    mqAddr := "amqp://" + *mqUser + ":" + *mqPass + "@" + *mqIp + ":" + strconv.Itoa(*mqPort)+"/"

    mqAddr := "amqp://guest:guest@" + *mqIp + ":" + strconv.Itoa(*mqPort)+"/"
    conn, err := amqp.Dial(mqAddr)
    if err != nil {
        log.Log.Infof("Failed to connect to RabbitMQ,err:",err)