go get -u gitee.com/tym_hmm/rabbitmq-pool-router-path-go

var wg sync.WaitGroup
exchangeName := "test-data-center-exchange-name"
exchangeType := RabbitmqPool.EXCHANGE_TYPE_TOPIC
queueName := "test-data-center-queue-name"
routeKey := "test-data"
routePath := "/test/a"


wg.Add(2)
go func() {
  defer wg.Done()
  data:="这是一个数据test/a"

  //Использование по умолчанию VirtualHosts для отправки
  //product:=RabbitmqRoute.NewProductClient(host, port, user, pwd)
  //Использование пользовательских VirtualHosts для отправки
  product:=RabbitmqRoute.NewProductClientVirtualHosts(host, port, user, pwd, "/temptest1")

  err:=product.Publish(exchangeName, exchangeType, queueName, routeKey, routePath, data)
  if err !=nil{
    fmt.Println(err)
  }
}()

go func() {
  defer wg.Done()
  routePatsh := "/testaa"
  datas:="这是一个数据test"
  //Использование по умолчанию VirtualHosts для отправки
  //products:=RabbitmqRoute.NewProductClient(host, port, user, pwd)
  //Использование пользовательских VirtualHosts для отправки
  products:=RabbitmqRoute.NewProductClientVirtualHosts(host, port, user, pwd, "/temptest1")
  errs:=products.Publish(exchangeName, exchangeType, queueName, routeKey, routePatsh, datas)
  if errs !=nil{
    fmt.Println(errs)
  }
}()

  wg.Wait()

consumer := RabbitmqRoute.NewTask(host, port, user, pwd)

  //Установка информации о загружаемом узле (временно поддерживает только присоединение одного узла)
consumer.SetHandleNode(&RabbitmqRoute.NodeInfo{
  NodeName:     "dataCenter",
  ExchangeName: "test-data-center-exchange-name",
  ExchangeType: RabbitmqPool.EXCHANGE_TYPE_TOPIC,
  Route:        "test-data",
  QueueName:    "test-data-center-queue-name",
  IsTry:        false,
  MaxReTry:     1,
})

  //Регистрация загруженного маршрута
consumer.RouteRegister(func(engine *RabbitmqRoute.TaskEngine) {
  //fmt.Println(engine)
  engine.AddRoute("/test", func(c *RabbitmqRoute.TaskContext) {
     fmt.Println(c.Request.Data)
   //c.Request.Data
  })
  engine.AddRoute("/test/a", func(c *RabbitmqRoute.TaskContext) {
    fmt.Println(c.Request.Data)
  })
})
  err := consumer.Enter()
  if err != nil {
    fmt.Println(err)
  }