 步驟一:安裝RabbitMQ 具體安裝可以參照作者的另外2篇文章 RabbitMQ在windows下的安裝 RabbitMQ在Linux下的安裝 步驟二:打開Rabbit的管理界面,地址為IP:15672

步驟三:在無登錄賬號的情況下,系統(tǒng)提供了默認的賬號:guest ,密碼:guest 注:guest可能出現(xiàn)登錄不上的情況,這里系統(tǒng)是默認只能在本地登錄guest這個賬號
 ,如需使用,需要去RabbitMQ配置文件配置。 配置流程:進入/usr/lib/rabbitmq/lib/rabbitmq_server-3.7.7/ebin/rabbit.app 將:{loopback_users, [<<”guest”>>]},改為:{loopback_users, []},重啟即可 重啟命令: systemctl restart rabbitmq-server.service
步驟四:添加一個交換機Exchanges 進入Exchanges
 點擊添加一個交換機
 輸入交換機的名字、類型、是否持久化,并點擊Add exchange 按鈕
 查看界面出現(xiàn)新的交換機,則成功
 步驟五:添加一個隊列 選擇Queues下的Add a new queue
 輸入隊列名和是否持久化,點擊Add queue
 查看界面上出現(xiàn)一個隊列,則成功
 步驟六:交換機和隊列綁定 點擊隊列名,進去詳情查看
 選擇Banding (綁定)
 輸入要綁定的交換機的名字和Routing key
Routing key :為匹配規(guī)則,只有相對應的Exchanges和Routing key才可以訪問到該隊列。比如Routing key=Abc,則只有Routing key=Abc可以訪問到該隊列。 Routing key=Abc.*的話,那么只有Abc.xxx可以訪問,Abc.xx.xx就不行
 點擊綁定,出現(xiàn)下列顯示則綁定成功
 步驟七:消息的推送 在java中配置rabbitmq,port一般為5672 下面${變量}形式為已經配置在了本地的環(huán)境變量中
 在java代碼中注入 @Autowired
private RabbitTemplate rabbitTemplate;
調用(對象被轉成了json格式): rabbitTemplate.convertAndSend("middle_exchanges","middle.save",new ObjectMapper().writeValueAsString(要傳輸的對象));
步驟八:查看消息 查看消息所在的隊列詳情,點擊Get Messages
 選擇查看即可  來源:https://www./content-4-393901.html
|