20190911 注册成功后发送mq消息

server/pom.xml

@@ -74,6 +74,11 @@
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>com.pica.cloud.foundation</groupId>
             <artifactId>pica-cloud-utils</artifactId>

server/src/main/java/com/pica/cloud/account/account/server/queue/QueueConfig.java

+package com.pica.cloud.account.account.server.queue;
+
+import org.springframework.amqp.core.*;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+/**
+ * Created on 2019/9/11 17:27
+ * author:crs
+ * Description:消息队列配置
+ */
+@Configuration
+public class QueueConfig {
+
+    public final static String QUEUE_NAME = "register_queue_account_13201";
+    public final static String EXCHANGE_NAME = "register_exchange";
+    public final static String ROUTE_KEY_NAME = "register_finish";
+    
+    /**
+     * 创建一个消息队列
+     *
+     * @return
+     */
+    @Bean
+    public Queue queue() {
+        return new Queue(QUEUE_NAME, true, false, true);
+    }
+
+    /**
+     * 创建交换机
+     *
+     * @return
+     */
+    @Bean
+    public TopicExchange directExchange() {
+        return new TopicExchange(EXCHANGE_NAME);
+    }
+
+    /**
+     * 把消息队里和交换机进行绑定
+     *
+     * @return
+     */
+    @Bean
+    public Binding binding() {
+        return BindingBuilder.bind(queue()).to(directExchange()).with(ROUTE_KEY_NAME);
+    }
+}

server/src/main/java/com/pica/cloud/account/account/server/queue/QueueProducer.java

+package com.pica.cloud.account.account.server.queue;
+
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * Created on 2019/9/11 17:37
+ * author:crs
+ * Description:消息生产者
+ */
+@Component
+public class QueueProducer {
+
+    @Autowired
+    private AmqpTemplate amqpTemplate;
+
+    /**
+     * 发送消息
+     *
+     * @param message
+     */
+    public void send(byte[] message) {
+        amqpTemplate.convertAndSend(QueueConfig.EXCHANGE_NAME, QueueConfig.ROUTE_KEY_NAME, message);
+    }
+}

server/src/main/java/com/pica/cloud/account/account/server/service/impl/RegisterServiceImpl.java

@@ -15,6 +15,7 @@ import com.pica.cloud.account.account.server.mapper.AccountInfoDetailMapper;
 import com.pica.cloud.account.account.server.mapper.AccountMapper;
 import com.pica.cloud.account.account.server.mapper.AccountPatientInfoMapper;
 import com.pica.cloud.account.account.server.mapper.DoctorMapper;
+import com.pica.cloud.account.account.server.queue.QueueProducer;
 import com.pica.cloud.account.account.server.req.BaseRequest;
 import com.pica.cloud.account.account.server.service.RegisterService;
 import com.pica.cloud.account.account.server.util.AccountUtils;
@@ -55,6 +56,9 @@ public class RegisterServiceImpl implements RegisterService {
     @Autowired
     private AccountUtils accountUtils;
 
+    @Autowired
+    private QueueProducer queueProducer;
+
     @Override
     public String register(BaseRequest baseRequest) {
         String mobile = EncryptCreateUtil.encrypt(baseRequest.getMobile());
@@ -117,6 +121,8 @@ public class RegisterServiceImpl implements RegisterService {
             JSONObject jsonObject = new JSONObject();
             jsonObject.put(Constants.TOKEN, newToken);
             jsonObject.put(Constants.USER_ID, userId);
+            //注册成功后发送mq消息，让别的服务初始化数据
+            queueProducer.send("1".getBytes());
             //记录登录日志
             LogLoginEntity entity = AccountLogEntityUtils.getLogLoginEntity(acctId, productType, baseRequest.getSourceType(),
                     AccountTypeEnum.LOGIN_REGISTER.getCode(), baseRequest.getLoginIp(), AccountTypeEnum.LOGIN_STATUS_SUCCESS.getCode(),

server/src/main/java/com/pica/cloud/account/account/server/util/MessageUtils.java

+package com.pica.cloud.account.account.server.util;
+
+/**
+ * Created on 2019/9/11 17:20
+ * author:crs
+ * Description:主要用于发送消息
+ */
+public class MessageUtils {
+
+    private final static String QUEUE_NAME = "queue_register";
+    private final static String EXCHANGE_NAME = "exchange_register";
+}

server/src/main/resources/bootstrap-dev.properties

 server.port=13201
 server.context-path=/account
 spring.application.name=${server.port}-pica-cloud-account
-
 #config server settings
 spring.cloud.config.name=com.pica.cloud.account
 spring.cloud.config.profile=dev
 spring.cloud.config.label=publish
 spring.cloud.config.discovery.enabled=true
 spring.cloud.config.discovery.service-id=config-server
-
 #eureka settings
 eureka.instance.instance-id=${spring.cloud.client.ipAddress}:${server.port}
 eureka.client.service-url.defaultZone=http://192.168.110.120:7891/eureka/,http://192.168.110.121:7891/eureka/
@@ -17,30 +15,25 @@ eureka.instance.lease-renewal-interval-in-seconds=10
 eureka.instance.lease-expiration-duration-in-seconds=10
 eureka.instance.hostname=${spring.cloud.client.ipAddress}
 eureka.instance.prefer-ip-address=true
-
 #logback settings
 logging.level.ROOT=INFO
 logging.path=c:/tomcat-log/${spring.application.name}
-
 #job settings
 #xxl.job.executor.appname=pica-cloud-${server.port}-account-job
-
 #feign settings
 feign.hystrix.enabled=false
 ribbon.ReadTimeout=120000
 ribbon.ConnectTimeout=60000
 #------------ Please don't change above configurations ------------
-
 spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
 spring.jackson.time-zone=GMT+8
-
 memcached.url=192.168.130.230:11211
-
 #微信登陆
 weChatAppID=wx5103ed453ef2dbe8
 weChatAppSecret=6faa9bef3302786c08b2baf278613f38
 weChatURL=https://api.weixin.qq.com/sns/userinfo?
 
+#是否开启双写模式，是否需要向p_doctor表写数据
 doubleWritingMode=true