好久没更新了。。实在太忙,对不起大家,今天更一下最近使用到的一些东西,比较实用!看官们亲拍~~
以前在单项目中用过RabbitMQ,没有问题
不过这次在分布式项目中使用RabbitMQ中有点搞糊涂了,但是实际上是没有问题的,思路清晰就行
简单看一下实际操作的示例吧:
资源文件中需要配置基本的rabbitMQ的属性,如下:
然后要配置applicationContext-rabbitmq.xml,这个文件需要新建,
当然你也可以在你的service.xml中编写,但是为了配置清晰嘛
内容如下:
这里需要注意acknowledge,这个属性默认是auto,如果消费者报错了,会一直报错,因为他是轮询监听的,可以修改为none或者manul
再看看实现的消费者以及助手类,助手类可以理解为service
监听3个routing-key
这样,直接调用componentImpl就行了!并且这3个都是异步的
为什么要使用RabbitMQ,那就是效率问题,有些主流程实现后,附流程你不在乎,成功不成功不影响,顶多重发一次,这样的业务可以使用消息队列
当然也有更多更复杂的也需要用的,这里的业务场景就比较简单了,好吧,看官们亲拍~