Golang Client 同时消费topic的问题

[loringgit]

看了example例子，消费消息的步骤是：
1.先创建Consumer（rmq_client.NewSimpleConsumer），可以指定多个topic
2.调用Start
3.通过Receive 轮询topic获取消息，Receive方法中有个轮询的逻辑貌似没起到轮询的作用，代码如下：

func (sc *defaultSimpleConsumer) Receive(ctx context.Context, maxMessageNum int32, invisibleDuration time.Duration) ([]*MessageView, error) {
	if !sc.isOn() {
		return nil, fmt.Errorf("simple consumer is not running")
	}
	if maxMessageNum <= 0 {
		return nil, fmt.Errorf("maxMessageNum must be greater than 0")
	}
	sc.subscriptionExpressionsLock.RLock()
	topics := make([]string, 0, len(sc.subscriptionExpressions))
	for k := range sc.subscriptionExpressions {
		topics = append(topics, k)
	}
	sc.subscriptionExpressionsLock.RUnlock()
	// All topic is subscribed.
	if len(topics) == 0 {
		return nil, fmt.Errorf("there is no topic to receive message")
	}
	next := atomic.AddInt32(&sc.topicIndex, 1)
	idx := utils.Mod(next+1, len(topics))
	topic := topics[idx]

上面这段代码中的topics 是map的key，是随机的，这里通过topicIndex 方式轮询的作用可能不生效

想问一下，一个NewSimpleConsumer下同时消费多个topic的情况下正确使用姿势是什么？如果只开启一个goroutine取轮询多个topic，有的topic的处理时间会很长（即使没有消息，也需要轮询），会影响其他topic的处理？

[francisoliverlee]

@loringgit

1. 一个NewSimpleConsumer下同时消费多个topic的情况下正确使用姿势是什么？
   是的。

2. 如果只开启一个goroutine取轮询多个topic，有的topic的处理时间会很长（即使没有消息，也需要轮询），会影响其他topic的处理？
   也可以用多个goruoutine. 参考java sdk的实现

[loringgit]

上面这段代码中的逻辑是希望通过topicIndex 方式轮询的多个topic吗？但是golang的特性，每次从map 的key顺序是随机的，也就是topics顺序每次都不一样，这个地方能否处理一下？
@francisoliverlee

[loringgit]

一个SimpleConsumer订阅多个topic，开启多个goroutine Receive消息的模式，需要对client进行调整，思路入下：
1）对Receive函数增加一个topic参数，比如ReceiveByTopic，
2）Start方法后，对每个topic开启goroutine，调用ReceiveByTopic
'''
func (sc *defaultSimpleConsumer) ReceiveByTopic(ctx context.Context, topic string, maxMessageNum int32, invisibleDuration time.Duration) ([]*MessageView, error) {

...这部份逻辑与Receive 类似
}
''''
多个goroutine 对同一个SimpleConsumer的场景，目前的client 代码是否足够线程安全？

[francisoliverlee]

上面这段代码中的逻辑是希望通过topicIndex 方式轮询的多个topic吗？但是golang的特性，每次从map 的key顺序是随机的，也就是topics顺序每次都不一样，这个地方能否处理一下？ @francisoliverlee

would be fixxed by mr

[francisoliverlee]

一个SimpleConsumer订阅多个topic，开启多个goroutine Receive消息的模式，需要对client进行调整，思路入下： 1）对Receive函数增加一个topic参数，比如ReceiveByTopic， 2）Start方法后，对每个topic开启goroutine，调用ReceiveByTopic ''' func (sc *defaultSimpleConsumer) ReceiveByTopic(ctx context.Context, topic string, maxMessageNum int32, invisibleDuration time.Duration) ([]*MessageView, error) {

...这部份逻辑与Receive 类似 } '''' 多个goroutine 对同一个SimpleConsumer的场景，目前的client 代码是否足够线程安全？

这里其实需要一个push consumer，简化消费操作。如果你有好的实现可以分享出来