在.Net中将RocketMQ跑起来_入门篇【2】
上一篇讲了如何再控制台将RocketMQ跑起来,本篇讲解,在asp.net mvc种跑起来,含(发布、订阅)。
本次将不挨个贴源码,直接展示目录,根据上一篇文章,进行相应的调整即可。
1.新建一个类库,将MQ公共部分提出来:
如:
2.新建一个asp.net mvc 项目(需要在App_Data中修改RocketMQ的相应配置):
在asp.net mvc Global种添加初始化RocketMQ和订阅代码(按照BootsShuTestTag进行订阅):
接下来可以在控制器调用RocketMQ,进行测试(发布消息的Tag为BootsShuTestTag,消费可以根据指定的Tag进行消费):
注意、注意、注意:
1.需要将项目统一编译成X64、并且将项目寄宿到IIS,里边即可正常运行。在VS里边运行,是跑不起来的!
2.作者不推荐在服务端进行订阅,大家根据自己的业务场景自行判断。