參考文章：rocketmq實戰
啟動rocketmq的namesrv
啟動rocketmq的broker
建立乙個簡單的springboot專案
pom
4.0.0
com.squid.rocketmq
rocketmq-test
1.0-snapshot
org.springframework.boot
spring-boot-starter-parent
2.0.0.release
org.apache.rocketmq
rocketmq-common
4.3.2
org.apache.rocketmq
rocketmq-client
4.3.2
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-starter-aop
#server.port=8080
#server.tomcat.uri-encoding=utf-8
server:
port: 8080
tomcat:
uri-encoding: utf-8
apache:
rocketmq:
###mq伺服器位址
namesrvaddr: localhost:9876
producer:
###生產者分組
producergroup: myproducer
###消費者名稱
consumer:
pushconsumer: mypushconsumer1
consumergroup: ***
@service
public class producerserviceimpl ")
private string producergroup;
@value("$")
private string namesrvaddr;
private defaultmqproducer producer;
@postconstruct
public void initproducer() catch (exception e)
}public string send(string topic, string tags, string msg) catch (exception e)
return "";
}@predestroy
public void shutdownproducer()
}}
@configuration
public class consumerlistener ")
private string consumergroup;
@value("$")
private string namesrvaddr;
@bean
public defaultmqpushconsumer defaultmqpushconsumer()
} catch (exception e)
return consumeconcurrentlystatus.consume_success;
});consumer.start();
system.out.println("[consumer 已啟動]");
} catch (exception e)
return consumer;
}}
@controller
public class mqcontroller
}
[producer] msgid(c0a800a328d018b4aac24138aaa20000) send_ok
[consumer] msgid(c0a800a328d018b4aac24138aaa20000) msgbody : 測試訊息
RocketMq入門 入門示例
網上眾說紛紜。有的說啟動命令不對，有的說rocketmq預設不允許開發者私自建立topic。最後手動建立topic。但是發現消費不了訊息，很奇怪。今天我又重新安裝了一遍rocketmq。測試了一下發現還可以。上圖是rocketmq的架構圖。我們必須要對上述的一些組建或者結點做一些說明解釋 produ...
RocketMq入門案例
修改社交會員 封裝傳送入參 socialmember socialmember newsocialmember socialmember setlastupd newdate 大資料要求設定修改時間 string getmid socialmember setmid request getdata ...
Python 入門實戰（二）
牛優果暑期python入門實戰第二彈 實戰時遇到的任何問題都可以在上課的時候向老師提出詢問！入門實戰第一彈問題回顧 計算1，3，5 97，99所有數字的總和 解法1 while 迴圈語句 sum 0 i 1 while i 100 sum sum i i i 2 print sum 詳解 首先初始化...