改为使用订阅服务

zheng-cms/zheng-cms-job/src/main/java/com/zheng/cms/job/jms/defaultQueueMessageListener.java

@@ -1,7 +1,7 @@
 package com.zheng.cms.job.jms;
 
 import com.zheng.cms.dao.model.CmsUser;
-import com.zheng.cms.service.UserService;
+import com.zheng.cms.rpc.api.UserService;
 import net.sf.json.JSONObject;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -43,7 +43,7 @@ public class defaultQueueMessageListener implements MessageListener {
                     if (user.getUsername().equals("1000")) {
                         _log.info("消费结束时间：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(System.currentTimeMillis())));
                     }
-                    userService.getMapper().insertSelective(user);
+                    userService.insertSelective(user);
                 } catch (Exception e) {
                     e.printStackTrace();
                 }

zheng-cms/zheng-cms-job/src/main/resources/applicationContext-dubbo-consumer.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	   xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
+	   xsi:schemaLocation="http://www.springframework.org/schema/beans
+        http://www.springframework.org/schema/beans/spring-beans.xsd
+        http://code.alibabatech.com/schema/dubbo
+        http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">
+
+	<dubbo:application name="zheng-upms-server"/>
+
+    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
+
+	<!-- 订阅服务 -->
+	<dubbo:reference id="cmsArticleService" interface="com.zheng.cms.rpc.api.CmsArticleService" />
+
+	<dubbo:reference id="cmsCategoryService" interface="com.zheng.cms.rpc.api.CmsCategoryService" />
+
+	<dubbo:reference id="cmsCommentService" interface="com.zheng.cms.rpc.api.CmsCommentService" />
+
+	<dubbo:reference id="cmsTagService" interface="com.zheng.cms.rpc.api.CmsTagService" />
+
+	<dubbo:reference id="userService" interface="com.zheng.cms.rpc.api.UserService" />
+
+</beans>

zheng-cms/zheng-cms-search/src/main/resources/applicationContext-dubbo-consumer.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	   xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
+	   xsi:schemaLocation="http://www.springframework.org/schema/beans
+        http://www.springframework.org/schema/beans/spring-beans.xsd
+        http://code.alibabatech.com/schema/dubbo
+        http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">
+
+	<dubbo:application name="zheng-upms-server"/>
+
+    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
+
+	<!-- 订阅服务 -->
+	<dubbo:reference id="cmsArticleService" interface="com.zheng.cms.rpc.api.CmsArticleService" />
+
+	<dubbo:reference id="cmsCategoryService" interface="com.zheng.cms.rpc.api.CmsCategoryService" />
+
+	<dubbo:reference id="cmsCommentService" interface="com.zheng.cms.rpc.api.CmsCommentService" />
+
+	<dubbo:reference id="cmsTagService" interface="com.zheng.cms.rpc.api.CmsTagService" />
+
+	<dubbo:reference id="userService" interface="com.zheng.cms.rpc.api.UserService" />
+
+</beans>