优化 Redis 连接数

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

@@ -108,7 +108,7 @@ public class ServiceCmdEventPublishing {
      *
      * @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 @@ public class ServiceCmdEventPublishing {
      * @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 @@ public class ServiceCmdEventPublishing {
      * @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-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 @@ public class CmdServiceSMOImpl extends LoggerEngine implements ICmdServiceSMO {
      * @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 @@ spring:
     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: