参考consumer思路
给suro添加RocketmqConsumer