合理發佈消息java
1.經過回執,通知服務器消息處理完成,經過回執,服務器能夠知道消費者有沒有處理完消息 2.qos=1 每次只從服務器抓取一條消息,這條消息處理完成以前,不會抓取下一條 必須在手動ACK模式下qos設置纔有效
消息持久化
防止服務器崩潰,重啓形成消息丟失,須要把消息保存到磁盤中mysql
1.隊列持久化 c.queueDeclare("隊列名",true,...) 2.消息設置持久化 c.basicPublish("","隊列名",MessageProperties.PERSISTENT_TEXT_PLAN,消息)
1.導入數據庫 sqlyog右鍵點擊鏈接 選擇"從sql轉儲文件導入" 億發課前資料\solr04-拼多數據庫\pd.sql 導入完成後,右鍵點擊鏈接,刷新 2.新建Empty Project: pd 3.導入模塊 1.E:\Stage6\課前資料\億發課前資料-2003\億發課前資料\億發課前資料\solr\06-拼多項目 2.解壓到pd工程目錄 4.數據庫鏈接 若是用oracle mysql8須要調數據庫驅動和鏈接參數 驅動用新版本8.0.21 yml中驅動類改爲com.mqsql.cj.jdbc.Driver 鏈接參數添加&serverTimezone=GMT2B8 5.mapper.xml 項目中mapper.xml直接放在了java目錄下 須要吧xml文件移動到resources目錄下 6.設置工程的jdk 7.啓動配置,設置working directory,設置成pd-web模塊目錄