合理发布消息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模块目录