# route-rabbitmq-client

**Repository Path**: tym_hmm/route-rabbitmq-client

## Basic Information

- **Project Name**: route-rabbitmq-client
- **Description**: rabbmtmq route 客户端封装(需自已处理业务逻辑)
- **Primary Language**: Go
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 6
- **Forks**: 0
- **Created**: 2021-10-26
- **Last Updated**: 2025-05-23

## Categories & Tags

**Categories**: message-server

**Tags**: None

## README

### rabbitmq 消息客户端处理

说明：
> 客户端只需修改 `DataCenterClient.go` 发送数据 及 `DataCenterInterface.go` 接口处理 实现自已的逻辑


### rabbitmq 路由服务端
[rabbitmqroute 服务路由端=>](https://gitee.com/tym_hmm/rabbitmq-pool-router-path-go.git)

### 获取组件包
```cgo
go get -u https://gitee.com/tym_hmm/route-rabbitmq-client.git
```


### 客户端接入demo
```cgo
	client := DataCenterClient.NewDataCenterClient("192.168.1.169",5672, "admin", "admin")
	client.SetExchange("test-data-center-exchange-name", RabbitmqPool.EXCHANGE_TYPE_TOPIC,"test-data-center-queue-name", "test-data")
	client.SetTerminalType(Conf.GetTerminalTypeSdk())

	devices:=&DataCenterClient.DeviceData{
		DeviceId:            "devidesId",
		Os:                  "os",
		Osv:                 "osv",
		Model:               "model",
		Brand:               "brand",
		Idfa:                "idfa",
		Imei:                "imei",
		AndroidId:           "androidId",
		AndroidAdId:         "androidAdId",
		OaId:                "aaId",
		HardwareMachine:     "hardwareMachine",
		HardwareModel:       "hardwareModel",
		MediaName:           "mediaName",
		MediaPackageName:    "mediaPackageName",
		MediaPackageVersion: "mediaPackageVersion",
		MediaPackageOsType:  "android",
		SdkVersion:          "sdkVersion",
	}

	channelList := []*DataCenterClient.ChannelInfo{}

	requestData:=&DataCenterClient.RequestData{
		OrderId:       "123456",
		DeviceId:      "123456",
		ChannelList:   channelList,
		//SdkType:       0, 底层会自动修改， 无需加入  通过 SetTerminalType() 来设置
		AppName:       "",
		SdkVersion:    "",
		AppVersion:    "",
		PackageName:   "",
		ErrInfo:       "",
		Ext:           "",
		//ReportTime:    "",无需定定义,底层会自动添加时间
	}
	err:=client.ReportRequest(devices, requestData)
	if err !=nil{
		fmt.Println("失败",err)
	}else{
		fmt.Println("成功")
	}
```