优化 Redis 连接数

wuxw

2022-09-14 bb62196bc1f5b2020e6a7467e25322fac3d39f51

优化 Redis 连接数

 java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java

@@ -108,7 +108,7 @@
     *
     * @param cmdDataFlowContext
     */
    public static void multicastEvent(ICmdDataFlowContext cmdDataFlowContext) throws BusinessException {
    public static void multicastEvent(ICmdDataFlowContext cmdDataFlowContext) throws Exception {
        Assert.notNull(cmdDataFlowContext.getServiceCode(), "当前没有可处理的业务信息！");
        multicastEvent(cmdDataFlowContext.getServiceCode(), cmdDataFlowContext, null);
    }
@@ -120,7 +120,7 @@
     * @param serviceCode
     * @param dataFlowContext
     */
    public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext) throws BusinessException {
    public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext) throws Exception {
        multicastEvent(serviceCode, dataFlowContext, null);
    }

@@ -130,14 +130,15 @@
     * @param serviceCode
     * @param dataFlowContext 这个订单信息，以便于 侦听那边需要用
     */
    public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext, String asyn) throws BusinessException {
    public static void multicastEvent(String serviceCode, ICmdDataFlowContext dataFlowContext, String asyn) throws Exception {
        try {
            CmdEvent targetDataFlowEvent = new CmdEvent(serviceCode, dataFlowContext);

            multicastEvent(serviceCode, targetDataFlowEvent, asyn);
        } catch (Exception e) {
            logger.error("发布侦听失败，失败原因为：", e);
            throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR, e.getMessage());
            //throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR, e.getMessage());
            throw e;
        }

    }

 java110-interface/src/main/resources/logback-dev.xml

File was renamed from java110-interface/src/main/resources/logback-prod.xml
@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds">

<!--    <include resource="org/springframework/boot/logging/logback/base.xml"/>-->
    <!--<include resource="org/springframework/boot/logging/logback/base.xml"/>-->

    <!-- 控制台输出 -->
    <appender name="STDOUT_FILE" class="ch.qos.logback.core.ConsoleAppender">
@@ -64,30 +64,27 @@
    <logger name="org.springframework" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="com.java110.api" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="com.java110.order" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>

    <!--myibatis log configure-->
    <logger name="com.apache.ibatis" level="ERROR">
    <logger name="com.apache.ibatis" level="DEBUG">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>

    <logger name="org.mybatis" level="ERROR">
    <logger name="org.mybatis" level="DEBUG">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="druid.sql.Statement" level="ERROR">
    <logger name="druid.sql.Statement" level="DEBUG">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="druid.sql.ResultSet" level="ERROR">
    <logger name="druid.sql.ResultSet" level="DEBUG">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>


    <logger name="com.java110" level="ERROR">
    <logger name="com.java110" level="DEBUG">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>


 java110-interface/src/main/resources/logback.xml

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds">

    <!--<include resource="org/springframework/boot/logging/logback/base.xml"/>-->
<!--    <include resource="org/springframework/boot/logging/logback/base.xml"/>-->

    <!-- 控制台输出 -->
    <appender name="STDOUT_FILE" class="ch.qos.logback.core.ConsoleAppender">
@@ -64,27 +64,30 @@
    <logger name="org.springframework" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="com.java110.api" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="com.java110.order" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>

    <!--myibatis log configure-->
    <logger name="com.apache.ibatis" level="DEBUG">
    <logger name="com.apache.ibatis" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>

    <logger name="org.mybatis" level="DEBUG">
    <logger name="org.mybatis" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="druid.sql.Statement" level="DEBUG">
    <logger name="druid.sql.Statement" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>
    <logger name="druid.sql.ResultSet" level="DEBUG">
    <logger name="druid.sql.ResultSet" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>


    <logger name="com.java110" level="DEBUG">
    <logger name="com.java110" level="ERROR">
        <appender-ref ref="STDOUT_FILE"/>
    </logger>


 java110-service/src/main/java/com/java110/service/smo/impl/CmdServiceSMOImpl.java

@@ -94,7 +94,7 @@
     * @param cmdDataFlowContext
     * @throws BusinessException
     */
    private void invokeBusinessSystem(ICmdDataFlowContext cmdDataFlowContext) throws BusinessException {
    private void invokeBusinessSystem(ICmdDataFlowContext cmdDataFlowContext) throws Exception {
        ServiceCmdEventPublishing.multicastEvent(cmdDataFlowContext);
    }


 springboot/src/main/resources/application-dev.yml

@@ -1,9 +1,10 @@
jedis:
  pool:
    config:
      maxTotal: 100
      maxIdle: 20
      maxWaitMillis: 20000
      maxTotal: 300
      maxIdle: 50
      minIdle: 20
      maxWaitMillis: 3000
    host: dev.redis.java110.com
    port: 6379
    timeout: 3000
@@ -43,9 +44,9 @@
    password: hc
    pool:
      max-active: 300
      max-wait: 10000
      max-idle: 100
      min-idle: 0
      max-wait: 3000
      max-idle: 50
      min-idle: 20
      timeout: 0

feign: