配置文件修改

admin

2019-11-23 17d029a7833fb79c0ab88ede2ff835a0ba173a23

配置文件修改

 fanli/src/main/resource/env-dev/mongo.properties

@@ -1,13 +1,13 @@
mongo.dbname=flq

mongo.port=27016



mongo.port=27017

#开发环境

#mongo.host=192.168.1.253

#mongo.username=admin

#mongo.password=123456

mongo.host=193.112.35.168

mongo.username=yeshi

mongo.password=Yeshi2016@

mongo.host=192.168.1.253

mongo.username=admin

mongo.password=123456



#mongo.host=193.112.35.168

#mongo.username=yeshi

#mongo.password=Yeshi2016@



mongo.connectionsPerHost=8

mongo.threadsAllowedToBlockForConnectionMultiplier=4


 fanli/src/main/resource/env-dev/redis.properties

@@ -1,7 +1,7 @@
redis.addr=192.168.1.253

redis.port=6379

redis.auth=123456

redis.max_active=1024

redis.max_total=1024

redis.max_idle=200

redis.max_wait=10000

redis.timeout=5000


 fanli/src/main/resource/env-dev/rocketmq.properties

@@ -1,3 +1,7 @@
rocketmq.AccessKey=LTAI4FwmTxVCuzTaoZtDiV8z
rocketmq.SecretKey=ixWg90QbYFKP6ae5xpAo2P1qwIyll5
#测试  http://MQ_INST_1205444665315884_Bbkj89nI.mq-internet-access.mq-internet.aliyuncs.com:80
#正式 http://MQ_INST_1205444665315884_BbaMbxF4.mq-internet-access.mq-internet.aliyuncs.com:80
rocketmq.NAMESRV_ADDR=http://MQ_INST_1205444665315884_Bbkj89nI.mq-internet-access.mq-internet.aliyuncs.com:80



 fanli/src/main/resource/env-pro-by/redis.properties

@@ -1,7 +1,7 @@
redis.addr=127.0.0.1

redis.port=6379

redis.auth=Yeshi2016@

redis.max_active=1024

redis.max_total=1024

redis.max_idle=200

redis.max_wait=10000

redis.timeout=5000


 fanli/src/main/resource/env-pro-job/redis.properties

@@ -1,7 +1,7 @@
redis.addr=172.16.16.15

redis.port=6379

redis.auth=crs-43yhgz0i:Yeshi2016@

redis.max_active=1024

redis.max_total=1024

redis.max_idle=200

redis.max_wait=10000

redis.timeout=5000


 fanli/src/main/resource/env-pro/redis.properties

@@ -1,7 +1,7 @@
redis.addr=172.16.16.15

redis.port=6379

redis.auth=crs-43yhgz0i:Yeshi2016@

redis.max_active=1024

redis.max_total=1024

redis.max_idle=200

redis.max_wait=10000

redis.timeout=5000


 fanli/src/main/resource/rocket/consumer.xml

@@ -93,12 +93,12 @@
        </property>

        <property name="subscriptionTable">

            <map>

                <!-- 产生订单，订单到账 -->

                <!-- 产生订单/延时，订单到账 -->

                <entry value-ref="redPackMessageListener">

                    <key>

                        <bean class="com.aliyun.openservices.ons.api.bean.Subscription">

                            <property name="topic" value="TOPIC_ORDER" />

                            <property name="expression" value="orderStatistic||orderFanLiActual" />

                            <property name="expression" value="orderStatistic||orderFanLiActual||orderStatisticDelay||orderFanLiSeparateByOrderNo" />

                        </bean>

                    </key>

                </entry>

@@ -116,4 +116,69 @@
            </map>

        </property>

    </bean>





    <!-- 金币消息订阅 -->

    <bean id="integralMessageListener"

        class="com.yeshi.fanli.util.rocketmq.consumer.integral.IntegralMessageListener"></bean>

    <!-- Group ID 订阅同一个 Topic，可以创建多个 ConsumerBean -->

    <bean id="integralConsumer" class="com.aliyun.openservices.ons.api.bean.ConsumerBean"

        init-method="start" destroy-method="shutdown">

        <property name="properties"> <!--消费者配置信息 -->

            <props>

                <prop key="AccessKey">${rocketmq.AccessKey}</prop>

                <prop key="SecretKey">${rocketmq.SecretKey}</prop>

                <prop key="GROUP_ID">GID_INTEGRAL</prop>

                <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop>

                <prop key="ConsumeThreadNums">50</prop>

            </props>

        </property>

        <property name="subscriptionTable">

            <map>

                <!-- 产生订单，订单到账 -->

                <entry value-ref="integralMessageListener">

                    <key>

                        <bean class="com.aliyun.openservices.ons.api.bean.Subscription">

                            <property name="topic" value="TOPIC_ORDER" />

                            <property name="expression" value="orderFanLiActual" />

                        </bean>

                    </key>

                </entry>

            </map>

        </property>

    </bean>

	
	
    <!-- 订单到账消息订阅 -->

    <bean id="orderMoneyRecievedMessageListener"

        class="com.yeshi.fanli.util.rocketmq.consumer.order.OrderMoneyRecievedMessageListener"></bean>

    <!-- Group ID 订阅同一个 Topic，可以创建多个 ConsumerBean -->

    <bean id="orderMoneyRecievedConsumer" class="com.aliyun.openservices.ons.api.bean.ConsumerBean"

        init-method="start" destroy-method="shutdown">

        <property name="properties"> <!--消费者配置信息 -->

            <props>

                <prop key="AccessKey">${rocketmq.AccessKey}</prop>

                <prop key="SecretKey">${rocketmq.SecretKey}</prop>

                <prop key="GROUP_ID">GID_FANLI</prop>

                <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop>

                <prop key="ConsumeThreadNums">50</prop>

            </props>

        </property>

        <property name="subscriptionTable">

            <map>

                <!-- 订单到账 -->

                <entry value-ref="orderMoneyRecievedMessageListener">

                    <key>

                        <bean class="com.aliyun.openservices.ons.api.bean.Subscription">

                            <property name="topic" value="TOPIC_ORDER" />

                            <property name="expression" value="orderFanLiActual" />

                        </bean>

                    </key>

                </entry>

            </map>

        </property>

    </bean>







</beans>

 fanli/src/main/resource/spring.xml

@@ -226,41 +226,18 @@




    <!-- redis连接池 -->

    <bean id="jedisConfig" class="redis.clients.jedis.JedisPoolConfig">

        <property name="maxActive" value="${redis.max_active}"></property>

    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

        <property name="maxTotal" value="${redis.max_total}"></property>

        <property name="maxIdle" value="${redis.max_idle}"></property>

        <property name="maxWait" value="${redis.max_wait}"></property>

        <property name="testOnBorrow" value="${redis.test_on_borrow}"></property>

    </bean>



    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">

        <constructor-arg name="poolConfig" ref="jedisConfig"></constructor-arg>

        <constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>

        <constructor-arg name="host" value="${redis.addr}"></constructor-arg>

        <constructor-arg name="port" value="${redis.port}"></constructor-arg>

        <constructor-arg name="timeout" value="${redis.timeout}"></constructor-arg>

        <constructor-arg name="password" value="${redis.auth}"></constructor-arg>

    </bean>



    <!-- redis连接工厂 -->

    <bean id="connectionFactory"

        class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">

        <property name="hostName" value="${redis.addr}"></property>

        <property name="port" value="${redis.port}"></property>

        <property name="password" value="${redis.auth}"></property>

        <property name="poolConfig" ref="jedisConfig"></property>

    </bean>



    <!-- redis操作模板，这里采用尽量面向对象的模板 -->

    <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">

        <property name="connectionFactory" ref="connectionFactory" />

        <property name="keySerializer">

            <bean

                class="org.springframework.data.redis.serializer.StringRedisSerializer" />

        </property>

        <property name="valueSerializer">

            <bean

                class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />

        </property>

    </bean>