代码优化

ipu-rest-demo/pom.xml

@@ -32,6 +32,7 @@
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<msgframe>1.9.2</msgframe>
		<jms>1.1</jms>
	</properties>
	<dependencies>
@@ -80,8 +81,13 @@
		<dependency>
			<groupId>com.ai.aif.msgframe</groupId>
  			<artifactId>msgframe-client</artifactId>
  			<version>1.9.2</version>
  			<version>${msgframe}</version>
  		</dependency>
  		<dependency>
		    <groupId>javax.jms</groupId>
		    <artifactId>jms</artifactId>
		    <version>${jms}</version>
		</dependency>
	</dependencies>
	<build>

ipu-rest-demo/src/main/resources/dev/dubbo-consumer-simple.xml

@@ -9,7 +9,8 @@
	<dubbo:application name="ipu-rest-demo" />
	<!-- 关闭重试，延长超时 -->
	<dubbo:consumer retries="0" timeout="2000"/>	<!-- client="netty4" -->
	<dubbo:registry address="127.0.0.1:20880" /> <!-- 127.0.0.1 -->
	<!-- 换成实际地址可以解决无法注册的异常 -->
	<dubbo:registry address="127.0.0.1:20880" />
	<!-- 全局配置 end=========================== -->
	<!-- 服务注册配置 start=========================== -->

ipu-service-demo/pom.xml

@@ -51,9 +51,9 @@
		</dependency>
		<!-- msgframe相关依赖 -->
		<dependency>
		  <groupId>com.ai.aif.msgframe</groupId>
		  <artifactId>msgframe-server</artifactId>
		  <version>${msgframe}</version>
		  	<groupId>com.ai.aif.msgframe</groupId>
		  	<artifactId>msgframe-server</artifactId>
		  	<version>${msgframe}</version>
		</dependency>
	</dependencies>
</project>

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

@@ -2,6 +2,9 @@ package com.ai.ipu.service;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.aif.msgframe.consumer.MfConsumerClient;
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";
@@ -14,9 +17,9 @@ public class IpuServiceDemoStart {
        context.start();
        /*启动消息中间件的消费者服务*/
        /*启动所有的订阅*/
        //MfServiceStartup.main();
        MfServiceStartup.main();
        /*启动指定的订阅*/
        //MfConsumerClient.subscribe("myTestTopic", "*", "com.ai.ipu.service.demo.consumer.ConsumerProcessorImpl");
        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

@@ -2,19 +2,21 @@ 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.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 class ConsumerProcessorImpl implements IConsumerProcessor {
    @SuppressWarnings("rawtypes")
    public Object process(MsgFMessage msg) throws ConsumerException{
        @SuppressWarnings("resource")
        ClassPathXmlApplicationContext context = 
                new ClassPathXmlApplicationContext(new String[] { IpuServiceDemoStart.DUBBO_CONSUMER_CONFIG });
        context.start();
@@ -29,5 +31,4 @@ import com.ailk.common.data.impl.DataMap;
        }
        return true;
    }
}*/
}