开源软件名称：

rabbitmq-pool-router-path-go

开源软件地址：

https://gitee.com/tym_hmm/rabbitmq-pool-router-path-go

开源软件介绍：

go rabbitMq 队列路由处理

描述

1、rabbitmq 使用同一交换机，队列， routekey, 监听队列后通过消息路由routePath 进行区分任务逻辑
一个消息队列可根据自定义路由处响应不通事件。支持不同队列不同路由处理，基于rabbitmq连接池

2、兼容rabbitmq链接池自定义 VirtualHosts

使用案例

生产项目已使用，每日处理上亿数据，每秒可处理1000+队列消息，rabbitmq集群及服务应用未出现较高压力

组件说明

基于rabbitmq连接池工具=>

接入说明

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

生产者声明

var wg sync.WaitGroupexchangeName := "test-data-center-exchange-name"exchangeType := RabbitmqPool.EXCHANGE_TYPE_TOPICqueueName := "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)  }