添加rocketmq测试接口

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/controller/View3dController.java

 package com.yeejoin.amos.fas.business.controller;
 
 import java.util.List;
+import java.util.Map;
 
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -318,4 +320,19 @@ public class View3dController extends BaseController {
 		return  CommonResponseUtil.success(view3dService.listPointsByRegionId(regionId,type));
 	}
 
+	 @Autowired
+	 private RocketMQTemplate rocketMQTemplate;
+	 
+	@ApiOperation(value = "rocketMQ消息推送测试", notes = "rocketMQ消息推送测试")
+	@PostMapping(value="rocketMQ/send")
+	public CommonResponse rocketMQTemplate(@RequestParam(required = true, defaultValue = "all") String topic,
+			@RequestBody Map msg) {
+		try {		
+			rocketMQTemplate.convertAndSend(topic, msg);
+		} catch (Exception e) {
+			return CommonResponseUtil.failure(e.getMessage());
+		}
+        return CommonResponseUtil.success(msg);
+    }
+	
 }

YeeAmosFireAutoSysStart/src/main/resources/application-dev.properties

@@ -51,7 +51,7 @@ emqx.user-name=admin
 emqx.password=public
 
 #rocketmq生产者配置
-rocketmq.name-server=localhost:9876
+rocketmq.name-server=172.16.3.51:9876
 rocketmq.producer.group=my-group
 rocketmq.producer.sendMessageTimeout=300000
 rocket-plan-topic=template_topic