fanli/src/main/resource/env-dev/rocketmq.properties
New file @@ -0,0 +1,3 @@ rocketmq.AccessKey=LTAI4FwmTxVCuzTaoZtDiV8z rocketmq.SecretKey=ixWg90QbYFKP6ae5xpAo2P1qwIyll5 rocketmq.NAMESRV_ADDR=http://MQ_INST_1205444665315884_Bbkj89nI.mq-internet-access.mq-internet.aliyuncs.com:80 fanli/src/main/resource/env-dev/rocketmq.xml
New file @@ -0,0 +1,9 @@ <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <import resource="classpath:/rocket/consumer.xml" /> <import resource="classpath:/rocket/system-coupon-consumer.xml"/> <import resource="classpath:/rocket/producer.xml" /> <import resource="classpath:/rocket/transactionProducer.xml" /> </beans> fanli/src/main/resource/env-pro-by/rocket/consumer.xml
File was deleted fanli/src/main/resource/env-pro-by/rocket/producer.xml
File was deleted fanli/src/main/resource/env-pro-by/rocket/system-coupon-consumer.xml
File was deleted fanli/src/main/resource/env-pro-by/rocket/transactionProducer.xml
File was deleted fanli/src/main/resource/env-pro-by/rocketmq.properties
New file @@ -0,0 +1,3 @@ rocketmq.AccessKey=LTAI4FwmTxVCuzTaoZtDiV8z rocketmq.SecretKey=ixWg90QbYFKP6ae5xpAo2P1qwIyll5 rocketmq.NAMESRV_ADDR=http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 fanli/src/main/resource/env-pro-by/rocketmq.xml
New file @@ -0,0 +1,7 @@ <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <import resource="classpath:/rocket/producer.xml" /> <import resource="classpath:/rocket/transactionProducer.xml" /> </beans> fanli/src/main/resource/env-pro-by/spring.xml
File was deleted fanli/src/main/resource/env-pro-job/rocket/consumer.xml
File was deleted fanli/src/main/resource/env-pro-job/rocket/producer.xml
File was deleted fanli/src/main/resource/env-pro-job/rocket/system-coupon-consumer.xml
File was deleted fanli/src/main/resource/env-pro-job/rocket/transactionProducer.xml
File was deleted fanli/src/main/resource/env-pro-job/rocketmq.properties
New file @@ -0,0 +1,3 @@ rocketmq.AccessKey=LTAI4FwmTxVCuzTaoZtDiV8z rocketmq.SecretKey=ixWg90QbYFKP6ae5xpAo2P1qwIyll5 rocketmq.NAMESRV_ADDR=http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 fanli/src/main/resource/env-pro-job/rocketmq.xml
New file @@ -0,0 +1,9 @@ <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <import resource="classpath:/rocket/consumer.xml" /> <import resource="classpath:/rocket/system-coupon-consumer.xml"/> <import resource="classpath:/rocket/producer.xml" /> <import resource="classpath:/rocket/transactionProducer.xml" /> </beans> fanli/src/main/resource/env-pro-job/spring.xml
File was deleted fanli/src/main/resource/env-pro/rocket/consumer.xml
File was deleted fanli/src/main/resource/env-pro/rocket/producer.xml
File was deleted fanli/src/main/resource/env-pro/rocket/system-coupon-consumer.xml
File was deleted fanli/src/main/resource/env-pro/rocket/transactionProducer.xml
File was deleted fanli/src/main/resource/env-pro/rocketmq.properties
New file @@ -0,0 +1,3 @@ rocketmq.AccessKey=LTAI4FwmTxVCuzTaoZtDiV8z rocketmq.SecretKey=ixWg90QbYFKP6ae5xpAo2P1qwIyll5 rocketmq.NAMESRV_ADDR=http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 fanli/src/main/resource/env-pro/rocketmq.xml
New file @@ -0,0 +1,7 @@ <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <import resource="classpath:/rocket/producer.xml" /> <import resource="classpath:/rocket/transactionProducer.xml" /> </beans> fanli/src/main/resource/env-pro/spring.xml
File was deleted fanli/src/main/resource/rocket/consumer.xml
File was renamed from fanli/src/main/resource/env-dev/rocket/consumer.xml @@ -9,11 +9,10 @@ init-method="start" destroy-method="shutdown"> <property name="properties"> <!--消费者配置信息 --> <props> <prop key="AccessKey">LTAI4FwmTxVCuzTaoZtDiV8z</prop> <prop key="SecretKey">ixWg90QbYFKP6ae5xpAo2P1qwIyll5</prop> <prop key="AccessKey">${rocketmq.AccessKey}</prop> <prop key="SecretKey">${rocketmq.SecretKey}</prop> <prop key="GROUP_ID">GID_ORDER</prop> <prop key="NAMESRV_ADDR">http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 </prop> <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop> <!--将消费者线程数固定为 50 个 <prop key="ConsumeThreadNums">50</prop> --> </props> </property> @@ -53,11 +52,10 @@ init-method="start" destroy-method="shutdown"> <property name="properties"> <!--消费者配置信息 --> <props> <prop key="AccessKey">LTAI4FwmTxVCuzTaoZtDiV8z</prop> <prop key="SecretKey">ixWg90QbYFKP6ae5xpAo2P1qwIyll5</prop> <prop key="AccessKey">${rocketmq.AccessKey}</prop> <prop key="SecretKey">${rocketmq.SecretKey}</prop> <prop key="GROUP_ID">GID_BANLI_SHOP_ORDER</prop> <prop key="NAMESRV_ADDR">http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 </prop> <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop> <!--将消费者线程数固定为 50 个 <prop key="ConsumeThreadNums">50</prop> --> </props> </property> @@ -86,11 +84,10 @@ init-method="start" destroy-method="shutdown"> <property name="properties"> <!--消费者配置信息 --> <props> <prop key="AccessKey">LTAI4FwmTxVCuzTaoZtDiV8z</prop> <prop key="SecretKey">ixWg90QbYFKP6ae5xpAo2P1qwIyll5</prop> <prop key="AccessKey">${rocketmq.AccessKey}</prop> <prop key="SecretKey">${rocketmq.SecretKey}</prop> <prop key="GROUP_ID">GID_RED_PACK</prop> <prop key="NAMESRV_ADDR">http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 </prop> <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop> <prop key="ConsumeThreadNums">50</prop> </props> </property> @@ -119,37 +116,4 @@ </map> </property> </bean> <!-- 应用内口令订阅 --> <bean id="interTokenMessageListener" class="com.yeshi.fanli.util.rocketmq.consumer.token.InterTokenMessageListener"></bean> <!-- Group ID 订阅同一个 Topic，可以创建多个 ConsumerBean --> <bean id="interTokenConsumer" class="com.aliyun.openservices.ons.api.bean.ConsumerBean" init-method="start" destroy-method="shutdown"> <property name="properties"> <!--消费者配置信息 --> <props> <prop key="AccessKey">LTAI4FwmTxVCuzTaoZtDiV8z</prop> <prop key="SecretKey">ixWg90QbYFKP6ae5xpAo2P1qwIyll5</prop> <prop key="GROUP_ID">GID_TOKEN</prop> <prop key="NAMESRV_ADDR">http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 </prop> <prop key="ConsumeThreadNums">50</prop> </props> </property> <property name="subscriptionTable"> <map> <!-- 口令到期 --> <entry value-ref="interTokenMessageListener"> <key> <bean class="com.aliyun.openservices.ons.api.bean.Subscription"> <property name="topic" value="TOPIC_USER" /> <property name="expression" value="tokenOutOfDate" /> </bean> </key> </entry> </map> </property> </bean> </beans> fanli/src/main/resource/rocket/producer.xml
File was renamed from fanli/src/main/resource/env-dev/rocket/producer.xml @@ -8,10 +8,9 @@ <!-- Spring 接入方式支持 Java SDK 支持的所有配置项 --> <property name="properties"> <!--生产者配置信息 --> <props> <prop key="AccessKey">LTAI4FwmTxVCuzTaoZtDiV8z</prop> <prop key="SecretKey">ixWg90QbYFKP6ae5xpAo2P1qwIyll5</prop> <prop key="NAMESRV_ADDR">http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 </prop> <prop key="AccessKey">${rocketmq.AccessKey}</prop> <prop key="SecretKey">${rocketmq.SecretKey}</prop> <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop> <!--将消费者线程数固定为 50 个 <prop key="ConsumeThreadNums">50</prop> --> </props> </property> fanli/src/main/resource/rocket/system-coupon-consumer.xml
File was renamed from fanli/src/main/resource/env-dev/rocket/system-coupon-consumer.xml @@ -9,11 +9,10 @@ init-method="start" destroy-method="shutdown"> <property name="properties"> <!--消费者配置信息 --> <props> <prop key="AccessKey">LTAI4FwmTxVCuzTaoZtDiV8z</prop> <prop key="SecretKey">ixWg90QbYFKP6ae5xpAo2P1qwIyll5</prop> <prop key="AccessKey">${rocketmq.AccessKey}</prop> <prop key="SecretKey">${rocketmq.SecretKey}</prop> <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop> <prop key="GROUP_ID">GID_SYSTEM_COUPON</prop> <prop key="NAMESRV_ADDR">http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 </prop> <!--将消费者线程数固定为 50 个 <prop key="ConsumeThreadNums">50</prop> --> </props> </property> @@ -29,6 +28,15 @@ </bean> </key> </entry> <!-- 券退回 --> <entry value-ref="systemCouponMessageListener"> <key> <bean class="com.aliyun.openservices.ons.api.bean.Subscription"> <property name="topic" value="GID_SYSTEM_COUPON" /> <property name="expression" value="systemCouponDrawback" /> </bean> </key> </entry> </map> </property> </bean> fanli/src/main/resource/rocket/transactionProducer.xml
File was renamed from fanli/src/main/resource/env-dev/rocket/transactionProducer.xml @@ -10,11 +10,10 @@ init-method="start" destroy-method="shutdown"> <property name="properties"> <!--事务消息生产者配置信息 --> <props> <prop key="AccessKey">LTAI4FwmTxVCuzTaoZtDiV8z</prop> <prop key="SecretKey">ixWg90QbYFKP6ae5xpAo2P1qwIyll5</prop> <prop key="AccessKey">${rocketmq.AccessKey}</prop> <prop key="SecretKey">${rocketmq.SecretKey}</prop> <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop> <prop key="GROUP_ID">GID_ORDER</prop> <prop key="NAMESRV_ADDR">http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80 </prop> </props> </property> <property name="localTransactionChecker" ref="localTransactionChecker"></property> fanli/src/main/resource/spring.xml
File was renamed from fanli/src/main/resource/env-dev/spring.xml @@ -45,16 +45,12 @@ <value>classpath:redis.properties</value> <value>classpath:druid.properties</value> <value>classpath:mongo.properties</value> <value>classpath:rocketmq.properties</value> </array> </property> </bean> <import resource="classpath:/rocket/consumer.xml"/> <!-- <import resource="classpath:/rocket/consumer.xml"/> <import resource="classpath:/rocket/system-coupon-consumer.xml"/> --> <import resource="classpath:/rocket/producer.xml" /> <import resource="classpath:/rocket/transactionProducer.xml" /> <import resource="classpath:rocketmq.xml" /> <!--异步定义推荐方式 <task:executor id="executor" pool-size="15" /> <task:scheduler id="scheduler" pool-size="30" /> <task:annotation-driven executor="executor"
