引入msgframe的Demo使用案例

ipu-rest-demo/pom.xml

@@ -14,6 +14,7 @@
	<url>http://maven.apache.org</url>
	<repositories>
		<!-- IPU相关仓库 -->
		<repository>
			<id>ipu</id>
			<name>ipu repository</name>
@@ -26,10 +27,21 @@
				<updatePolicy>always</updatePolicy>
			</snapshots>
		</repository>
		<!-- AFI私服，内网私服 -->
		<repository>
			<id>aif_group</id>
			<url>http://10.11.20.81:8080/nexus/content/groups/aif_group/</url>
		</repository>
		<repository>
			<id>msgframe</id>
			<name>msgframe</name>
			<url>http://10.11.20.81:8080/nexus/content/repositories/msgframe/</url>
		</repository>
	</repositories>
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<msgframe>2.0.0</msgframe>
	</properties>
	<dependencies>
@@ -61,6 +73,18 @@
			<groupId>com.ai.ipu</groupId>
			<artifactId>ipu-server-web</artifactId>
		</dependency>
		
		<!-- msgframe相关依赖 -->
		<dependency>
			<groupId>msgframe</groupId>
			<artifactId>msgframe-client</artifactId>
			<version>${msgframe}</version>
		</dependency>
		<dependency>
			<groupId>msgframe</groupId>
			<artifactId>msgframe-common</artifactId>
			<version>${msgframe}</version>
		</dependency>
	</dependencies>
	<build>
@@ -80,6 +104,21 @@
					<mainClass>com.ai.ipu.server.demo.IpuRestDemoStart</mainClass>
				</configuration>
			</plugin>
			
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<configuration>
					<source>1.8</source>
					<target>1.8</target>
					<encoding>UTF-8</encoding>
					<!-- 这里添加本地jar -->
					<compilerArguments>
 					<bootclasspath>${JAVA_HOME}/jre/lib/rt.jar</bootclasspath>
 					<extdirs>${project.basedir}/libs</extdirs>
					</compilerArguments>
				</configuration>
			</plugin>
		</plugins>
		<finalName>${project.artifactId}</finalName>
	</build>

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/other/MsgFrameController.java

@@ -0,0 +1,36 @@
package com.ai.ipu.server.demo.control.other;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.aif.msgframe.MfProducerClient;
import com.ai.aif.msgframe.common.message.MsgFTextMessage;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.restful.util.IpuRestConstant;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@Controller
@RequestMapping("/msgframe")
public class MsgFrameController{
    @ResponseBody
    @RequestMapping("/produce")
    public IData produceMessage(IData params){
        IData result = new DataMap();
        try {
            MfProducerClient client = new MfProducerClient();
            MsgFTextMessage message = new MsgFTextMessage();
            message.setText(params.toString());
            client.send("myTestTopic", message);
        } catch (Throwable e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            IpuUtility.error(e);
        }
        result.put(IpuRestConstant.IPU_RESULT_CODE, IpuRestConstant.ResultCode.SUCCESS_CODE);
        result.put(IpuRestConstant.IPU_RESULT_INFO, "success");
        return result;
    }
}

ipu-rest-demo/src/main/resources/msgframe-config.xml

@@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<msgframeCfg xmlns="http://www.asiainfo.com/msgframe">
	<centerCfg>
		<!--［1-1］ 中心名称  定义当前中心或者当前系统的名称编码，全局配置唯一性-->
		<name>orderCenter</name>
		<!-- 全局配置  影响全局的一些参数配置，如入职中心的开关配置，整体的序列化方式等，全局配置唯一性 -->
		<globalCfg>
			<!-- 消息生产端消息注入处理类，可以不配或者多配，在发送时可以在消息发送前执行，配置类的全路径且继承接口 com.cmos.msgframe.common.IProsInjectionProcessor -->
			<!-- 		<prodInjection>sadsa</prodInjection> -->
			<!-- 消息消费端消息注入处理类，可以不配或者多配，在消费时可以在消息处理业务前执行，配置类的全路径且继承接口 com.cmos.msgframe.common.IConsInjectionProcessor -->
			<!-- 		<consInjection>sadsa</consInjection> -->
		</globalCfg>
		<!-- 总的主题列表配置信息，包含所有的主题配置信息，全局配置唯一性 -->
		<destinations>
		    <queue name="myTestTopic" belong="orderCenter"/>
		</destinations>
		<!-- 消费端的配置信息，主要包含订阅的主题和消息的业务实现类，全局配置唯一性 -->
		<subscribes>
		    <!-- 主题订阅信息，订阅在<destinations></destinations>标签中的主题消息 -->
		    <subscribe subDestination="myTestTopic" consumeType="push">
				<implclass>com.ai.ipu.bit.push.msgframe.consumer.ConsumerProcessorImpl</implclass>
			</subscribe>
		</subscribes>
		<!-- 主要配置中心(系统)和其所属集群的关系，全局配置唯一性 -->
		<centers>
			<center name="orderCenter" containClusters="cluster-1" />
		</centers>
		<!-- 集群配置，主要配置当前中心或者系统用到的所有集群信息，全局配置唯一性 -->
		<clusters>
		<!--RocketMQ、Kafka、ActiveMQ  -->
			<cluster name="cluster-1" type="RocketMQ">
					<!-- 本地搭建的RocketMQ -->
  				    <!-- <url>10.211.55.4:9876</url> -->
  				    <!--阿里云部署的RocketMQ -->
  				    <url>101.200.53.108:9876</url>
			</cluster>
		</clusters>
		<!-- 持久化配置区，主要包括生产端和消费端的异常持久化配置、生产端和消费端的日志持久化配置，全局配置唯一性 -->
		<persistence>
			<exceptionPersistence>
				<!-- 生产者异常处理,必须实现com.ai.aif.msgframe.common.ex.exception.IExceptionPersitence接口 -->
				<producerExceptionClass>com.ai.aif.msgframe.producer.ex.ProducerExceptionHandle</producerExceptionClass>
				<!-- 消费者异常处理,必须实现com.ai.aif.msgframe.common.ex.exception.IExceptionPersitence接口 -->
				<consumerExceptionClass>com.ai.aif.msgframe.consumer.ex.ConsumerExceptionHandle</consumerExceptionClass>
			</exceptionPersistence>
		</persistence>
	</centerCfg>
</msgframeCfg>

ipu-service-demo/pom.xml

@@ -23,10 +23,21 @@
				<updatePolicy>always</updatePolicy>
			</snapshots>
		</repository>
		<!-- AFI私服，内网私服 -->
		<repository>
			<id>aif_group</id>
			<url>http://10.11.20.81:8080/nexus/content/groups/aif_group/</url>
		</repository>
		<repository>
			<id>msgframe</id>
			<name>msgframe</name>
			<url>http://10.11.20.81:8080/nexus/content/repositories/msgframe/</url>
		</repository>
	</repositories>
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<ipu>3.0-SNAPSHOT</ipu>
		<msgframe>2.0.0</msgframe>
	</properties>
	<dependencies>
@@ -54,6 +65,17 @@
			<version>4.1.8.Final</version>
		</dependency>
		-->
		<!-- msgframe相关依赖 -->
		<dependency>
			<groupId>msgframe</groupId>
			<artifactId>msgframe-server</artifactId>
			<version>${msgframe}</version>
		</dependency>
		<dependency>
			<groupId>msgframe</groupId>
			<artifactId>msgframe-common</artifactId>
			<version>${msgframe}</version>
		</dependency>
	</dependencies>
	
	<!-- 对应开发、测试、生产三种环境 -->
@@ -93,6 +115,21 @@
					<skip>true</skip>
				</configuration>
			</plugin>
			
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<configuration>
					<source>1.8</source>
					<target>1.8</target>
					<encoding>UTF-8</encoding>
					<!-- 这里添加本地jar -->
					<compilerArguments>
 					<bootclasspath>${JAVA_HOME}/jre/lib/rt.jar</bootclasspath>
 					<extdirs>${project.basedir}/libs</extdirs>
					</compilerArguments>
				</configuration>
			</plugin>
		</plugins>
		<resources>
            <resource>

ipu-service-demo/src/main/java/com/ai/ipu/service/DubboServiceStart.java

@@ -2,7 +2,9 @@ package com.ai.ipu.service;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class DubboServiceStart {
import com.ai.aif.msgframe.consumer.MfServiceStartup;
public class IpuServiceDemoStart {
    public final static String MODE = "simple";
    public final static String DUBBO_PROVIDER_CONFIG = "dubbo-provider-" + MODE + ".xml";
    public final static String DUBBO_CONSUMER_CONFIG = "dubbo-consumer-" + MODE + ".xml";
@@ -12,6 +14,11 @@ public class DubboServiceStart {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] {DUBBO_PROVIDER_CONFIG});
        context.start();
        /*启动消息中间件的消费者服务*/
        /*启动所有的订阅*/
        MfServiceStartup.main();
        /*启动指定的订阅*/
//        MfConsumerClient.subscribe("myTestTopic", "*", "com.ai.ipu.service.demo.consumer.ConsumerProcessorImpl");
        System.in.read(); // press any key to exit
    }
}

ipu-service-demo/src/main/java/com/ai/ipu/service/demo/consumer/ConsumerProcessorImpl.java

@@ -0,0 +1,33 @@
package com.ai.ipu.service.demo.consumer;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.aif.msgframe.common.IConsumerProcessor;
import com.ai.aif.msgframe.common.exception.ConsumerException;
import com.ai.aif.msgframe.common.message.MsgFMessage;
import com.ai.aif.msgframe.common.message.MsgFTextMessage;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IDbService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
public class ConsumerProcessorImpl implements IConsumerProcessor {
    public Object process(MsgFMessage msg) throws ConsumerException{
        ClassPathXmlApplicationContext context = 
                new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
        String text = ((MsgFTextMessage)msg).getText();
        IData param = new DataMap(text);
        IDbService dbService = (IDbService) context.getBean("dbService");
        try {
            IData result = dbService.select(param);
            System.out.println("数据库查询结果为：" + result);
        }catch (Exception e) {
            e.printStackTrace();
        }
        return true;
    }
}

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/AsyncServiceTest.java

@@ -6,7 +6,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IAsyncService;
import com.ailk.common.data.IData;
import com.alibaba.dubbo.rpc.RpcContext;
@@ -17,7 +17,7 @@ public class AsyncServiceTest extends TestCase{
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/BizServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IBizService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@@ -15,7 +15,7 @@ public class BizServiceTest extends TestCase {
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/CallBackServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.ICallbackService;
import com.ai.ipu.service.demo.ICallbackService.ICallbackListener;
@@ -14,7 +14,7 @@ public class CallBackServiceTest extends TestCase {
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/ContextServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IContextService;
import com.ai.ipu.service.dubbo.DubboContextData;
import com.ailk.common.data.IData;
@@ -16,7 +16,7 @@ public class ContextServiceTest extends TestCase{
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/DbServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IDbService;
import com.ailk.common.data.IData;
@@ -14,7 +14,7 @@ public class DbServiceTest extends TestCase {
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/EchoServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.alibaba.dubbo.rpc.service.EchoService;
public class EchoServiceTest extends TestCase{
@@ -13,7 +13,7 @@ public class EchoServiceTest extends TestCase{
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/InterceptorServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IBizService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@@ -15,7 +15,7 @@ public class InterceptorServiceTest extends TestCase{
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/MockServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IMockService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@@ -15,7 +15,7 @@ public class MockServiceTest extends TestCase{
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/RestrictedServiceTest.java

@@ -2,7 +2,7 @@ package com.ai.ipu.service.demo.impl;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IMockService;
import com.ai.ipu.service.demo.IRestrictedService;
import com.ailk.common.data.IData;
@@ -16,7 +16,7 @@ public class RestrictedServiceTest extends TestCase{
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/StubServiceTest.java

@@ -4,7 +4,7 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IStubService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@@ -15,7 +15,7 @@ public class StubServiceTest extends TestCase{
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context = new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }