上一篇講瞭如何再控制台將RocketMQ跑起來,本篇講解,在asp.net mvc種跑起來,含(發佈、訂閱)。 本次將不挨個貼源碼,直接展示目錄,根據上一篇文章,進行相應的調整即可。 1.新建一個類庫,將MQ公共部分提出來: 如: 2.新建一個asp.net mvc 項目(需要在App_Data中修 ...
上一篇講瞭如何再控制台將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.作者不推薦在服務端進行訂閱,大家根據自己的業務場景自行判斷。