修改配置

webapidemo-api/src/main/java/com/example/controller/wechat/WxSignatureCheckService.java

@@ -1,5 +1,6 @@
 package com.example.controller.wechat;
 
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -8,8 +9,9 @@ import java.util.Arrays;
 @Service
 public class WxSignatureCheckService {
 
-    //token
-    private final String token = "wxtoken";
+
+    @Value("${spring.wechat.Token}")
+    private String token;
 
     public String wxSignatureCheck(String signature, String timestamp, String nonce, String echostr) {
         ArrayList<String> array = new ArrayList<String>();

webapidemo-api/src/main/resources/application-dev.yml

@@ -68,3 +68,28 @@ spring:
     password:
     # 连接超时时间
     timeout: 10s
+  rabbitmq:
+    host: 192.168.1.200
+    port: 5672
+    username: admin
+    password: 123456
+    virtual-host: /
+    #确认消息已发送到交换机(Exchange)
+    publisher-confirm-type: correlated
+    #确认消息已发送到队列(Queue)
+    publisher-returns: true
+    listener:
+      #      direct:
+      #        auto-startup: false
+      simple:
+        retry:
+          enabled: true           # 开启消费者出现异常情况下，进行重试消费，默认false
+          max-attempts: 3         # 最大重试次数，默认为3
+          initial-interval: 3000  # 重试间隔时间，默认1000(单位毫秒)
+    #        auto-startup: false
+
+  wechat:
+    AppId: wx4ff77198ae11494b
+    AppSecret: 2142698972a706a651f371e412d48a78
+    Token: wxtoken
+    EncodingAESKey:

webapidemo-api/src/main/resources/application-production.yml

@@ -2,16 +2,43 @@ server:
   port: 8000
 swagger: false
 spring:
-  datasource:
-    type: com.alibaba.druid.pool.DruidDataSource
-    druid:
-      url: jdbc:mysql://192.168.1.200:3306/jiayi?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8
-      username: root
-      password: 800100
-      driver-class-name: com.mysql.cj.jdbc.Driver
+  shardingsphere:
+    datasource:
+      names: master,slave0,slave1
+      master:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.cj.jdbc.Driver
+        url: jdbc:mysql://10.160.153.119:3306/jiayi?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
+        username: root
+        password: 123456
+      slave0:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.cj.jdbc.Driver
+        url: jdbc:mysql://10.160.153.119:3306/jiayi?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
+        username: root
+        password: 123456
+      slave1:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.cj.jdbc.Driver
+        url: jdbc:mysql://10.160.153.119:3306/jiayi?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
+        username: root
+        password: 123456
+    rules:
+      readwrite-splitting:
+        data-sources:
+          mds:
+            type: static
+            props:
+              write-data-source-name: master
+              read-data-source-names: slave0,slave1
+            load-balancer-name: read-random
+        load-balancers:
+          read-random:
+            type: round_robin
+    enabled: true
   redis:
     # 地址
-    host: 192.168.1.200
+    host: 10.160.153.119
     # 端口，默认为6379
     port: 6379
     # 数据库索引
@@ -20,3 +47,37 @@ spring:
     password:
     # 连接超时时间
     timeout: 10s
+  data:
+    mongodb:
+      authentication-database: admin
+      host: 10.160.153.119
+      port: 27017
+      database: wechat
+      username: root
+      password: '123456'
+
+  rabbitmq:
+    host: 10.160.153.119
+    port: 5672
+    username: admin
+    password: 123456
+    virtual-host: /
+    #确认消息已发送到交换机(Exchange)
+    publisher-confirm-type: correlated
+    #确认消息已发送到队列(Queue)
+    publisher-returns: true
+    listener:
+      #      direct:
+      #        auto-startup: false
+      simple:
+        retry:
+          enabled: true           # 开启消费者出现异常情况下，进行重试消费，默认false
+          max-attempts: 3         # 最大重试次数，默认为3
+          initial-interval: 3000  # 重试间隔时间，默认1000(单位毫秒)
+  #        auto-startup: false
+
+  wechat:
+    AppId: wx4ff77198ae11494b
+    AppSecret: 2142698972a706a651f371e412d48a78
+    Token: wxtoken
+    EncodingAESKey:

webapidemo-api/src/main/resources/application.yml

@@ -3,8 +3,8 @@ spring:
     date-format: yyyy-MM-dd HH:mm:ss
     time-zone: GMT+8
   profiles:
-    #active: production
-    active: dev
+    active: production
+    #active: dev
 
   resources:
     static-locations: file:/home/website/webapidemo/Api/file/image/  #资源路径
@@ -15,25 +15,6 @@ spring:
     multipart:
       max-file-size: 20MB #单个文件最大为20M
       max-request-size: 20MB #单次请求文件总数大小为20M
-  rabbitmq:
-    host: 192.168.1.200
-    port: 5672
-    username: admin
-    password: 123456
-    virtual-host: /
-      #确认消息已发送到交换机(Exchange)
-    publisher-confirm-type: correlated
-      #确认消息已发送到队列(Queue)
-    publisher-returns: true
-    listener:
-#      direct:
-#        auto-startup: false
-      simple:
-        retry:
-          enabled: true           # 开启消费者出现异常情况下，进行重试消费，默认false
-          max-attempts: 3         # 最大重试次数，默认为3
-          initial-interval: 3000  # 重试间隔时间，默认1000(单位毫秒)
-#        auto-startup: false
 mybatis-plus:
   global-config:
     db-config:

webapidemo-service/src/main/java/com/example/service/rabbitmqListener/Consumer.java

@@ -253,10 +253,10 @@ public class Consumer {
             String path = null;
             if ("image".equals(msgType)) {
                 file = new File(pathName, l + ".jpg");
-                path = "http://192.168.1.15:8000/image/" + format + "/" + l + ".jpg";
+                path = "/image/" + format + "/" + l + ".jpg";
             } else if ("video".equals(msgType)) {
                 file = new File(pathName, l + ".mp4");
-                path = "http://192.168.1.15:8000/image/" + format + "/" + l + ".mp4";
+                path = "/image/" + format + "/" + l + ".mp4";
                 mongoDBMessage.setThumbMediaId(queueMessage.getThumbMediaId());
             } else if ("voice".equals(msgType) || "audio".equals("msgType")) {
                 file = new File(pathName, l + ".amr");
@@ -288,7 +288,7 @@ public class Consumer {
                     String newPath = "file/image/" + format;
                     File voiceFile = new File(newPath, l + ".mp3");
                     DloadImgUtil.formatConversion(file, voiceFile);
-                    String voice = "http://192.168.1.15:8000/image/" + format + "/" + l + ".mp3";
+                    String voice = "/image/" + format + "/" + l + ".mp3";
 
                     mongoDBMessage.setPicUrl(voice);
                     FileUtil.deleteTempFile(file);

webapidemo-util/src/main/java/com/example/util/config/RabbitConfig.java

@@ -6,6 +6,7 @@ import org.springframework.amqp.core.AmqpAdmin;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.amqp.support.converter.MessageConverter;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -14,14 +15,24 @@ import org.springframework.context.annotation.Configuration;
  */
 @Configuration
 public class RabbitConfig {
+
+    @Value("${spring.rabbitmq.host}")
+    private static String host;
+    @Value("${spring.rabbitmq.port}")
+    private static int port;
+    @Value("${spring.rabbitmq.username}")
+    private static String username;
+    @Value("${spring.rabbitmq.password}")
+    private static String password;
+
     public static Connection getConnection() {
         Connection connection = null;
         try {
             ConnectionFactory factory = new ConnectionFactory();
-            factory.setHost("192.168.1.200");
-            factory.setPort(5672);
-            factory.setUsername("admin");
-            factory.setPassword("123456");
+            factory.setHost(host);
+            factory.setPort(port);
+            factory.setUsername(username);
+            factory.setPassword(password);
             connection = factory.newConnection();
         } catch (Exception e) {
             e.printStackTrace();

webapidemo-util/src/main/java/com/example/util/config/WxMpConfig.java

@@ -3,6 +3,7 @@ package com.example.util.config;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
 import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -13,17 +14,26 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class WxMpConfig {
 
+	@Value("${spring.wechat.AppId}")
+	private String AppId;
+	@Value("${spring.wechat.AppSecret}")
+	private String AppSecret;
+	@Value("${spring.wechat.Token}")
+	private String Token;
+	@Value("${spring.wechat.EncodingAESKey}")
+	private String EncodingAESKey;
+
 	@Bean
-		public WxMpDefaultConfigImpl wxMpDefaultConfigImpl() {
+	public WxMpDefaultConfigImpl wxMpDefaultConfigImpl() {
 		WxMpDefaultConfigImpl config = new WxMpDefaultConfigImpl();
 		// 设置微信公众号的appid
-		config.setAppId("wx4ff77198ae11494b");
+		config.setAppId(AppId);
 		// 设置微信公众号的app corpSecret
-		config.setSecret("2142698972a706a651f371e412d48a78");
+		config.setSecret(AppSecret);
 		// 设置微信公众号的token
-		config.setToken("wxtoken");
+		config.setToken(Token);
 		// 设置微信公众号的EncodingAESKey
-		config.setAesKey("");
+		config.setAesKey(EncodingAESKey);
 		return config;
 	}
 
@@ -35,6 +45,4 @@ public class WxMpConfig {
 		return wxMpService;
 	}
 
-
-
-}
+}