@IPU_REQ_2021@添加springcloud consumer示例

ipu-rest-demo/pom.xml

@@ -68,6 +68,21 @@
				<type>pom</type>
				<scope>import</scope>
			</dependency>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Greenwich.RELEASE</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
			<dependency>
				<groupId>com.alibaba.cloud</groupId>
				<artifactId>spring-cloud-alibaba-dependencies</artifactId>
				<version>${org.springframework.boot}</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>
@@ -122,7 +137,15 @@
			<artifactId>mysql-connector-java</artifactId>
			<version>8.0.17</version>
		</dependency>
		
		<!-- nacos -->
		<dependency>
			<groupId>com.alibaba.cloud</groupId>
			<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
		</dependency>
		<dependency>
			<groupId>com.alibaba.cloud</groupId>
			<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
		</dependency>
	</dependencies>
	<build>
@@ -132,13 +155,11 @@
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
				<version>2.4.5</version>
				
				    <configuration>
      <image>
        <name>megale/${project.artifactId}:${project.version}</name>
      </image>
    </configuration>
				
                        <image>
                            <name>megale/${project.artifactId}:${project.version}</name>
                        </image>
                     </configuration>			
			</plugin>
			<!-- 添加docker镜像功能 -->
			<plugin>

ipu-rest-demo/readme.md

@@ -1,5 +1,7 @@
一、启动服务脚本范例：java -Dipu.lic.path=D:/git/rest-guide/ipu-rest-demo/ipu.lic -jar target/ipu-rest-demo.jar  --server.port=8080
注意事项:需要增加证书。参数格式[-Dipu.lic.path]
由于增加了dubbo的consumer代码，需要事先启动dubbo的provider服务后再启动ipu-rest-demo。
二、区分context-path、servlet-path、static-path，正确配置拦截器的exclude-mapping
三、待办事项

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/config/NacosConfig.java

@@ -0,0 +1,106 @@
package com.ai.ipu.server.demo.config;
import java.util.Properties;
import java.util.concurrent.Executor;
import javax.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import com.ai.ipu.basic.string.StringUtil;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import lombok.extern.slf4j.Slf4j;
//springcloud也支持在程序中手工注册到配置中心，此时就可以监听到配置中心推送的配置文件。
//springcloud已经不再支持@NacosConfigListener，配置了也不生效。
@Component
@Slf4j
public class NacosConfig {
	private String service002Url;
	private String service002Param;
	
	@Bean(name="getService002Url")
	public String getService002Url() {
		return service002Url;
	}
	
	@Bean(name="getService002Param")
	public String getService002Param() {
		return service002Param;
	}
	
	
	@Value("${spring.cloud.nacos.config.server-addr}")
    private String nacosConfigServer;
	@Value("${spring.cloud.nacos.namespace}")
    private String nacosNamespace;
	
	@Value("${spring.cloud.nacos.dataid}")
    private String dataId;
	@Value("${spring.cloud.nacos.group}")
    private String group;
	@Value("${spring.cloud.nacos.timeout}")
    private long timeout;
	
	@PostConstruct
	public void initConfigServer() {
		try {
	        Properties properties = new Properties();
	        if (!StringUtil.isEmpty(nacosNamespace))
	        	properties.put(PropertyKeyConst.NAMESPACE, nacosNamespace);
	        properties.put(PropertyKeyConst.SERVER_ADDR, nacosConfigServer);
	        ConfigService configService = NacosFactory.createConfigService(properties);
	        String content = configService.getConfig(dataId, group, timeout);
	        //从配置中心获取到指定配置，需要自己解析后给service002Url、service002Param赋值
	        log.debug(content);
	        dealConfigServerConfig(content);
	        configService.addListener(dataId, group, new Listener() {
	            @Override
	            public void receiveConfigInfo(String configInfo) {
	            	//从配置中心获取到推送来的更新配置信息，需要自己解析给service002Url、service002Param赋值
	            	log.debug(configInfo);
	            	dealConfigServerConfig(configInfo);
	            }
	
	            @Override
	            public Executor getExecutor() {
	                return null;
	            }
	        });
	    } catch (NacosException e) {
	        log.error(e.getMessage());
	    }
	}
	
	private void dealConfigServerConfig(String configInfo) {
		if (StringUtil.isEmpty(configInfo))
			return;
		String[] configs = configInfo.split("\n\r|\n|\r|\r\n");
		int i=0;
		for (;i<configs.length;i++) {
			if (!StringUtil.isEmpty(configs[i]))
			{
				if (configs[i].indexOf("service002Url")>=0)
				{
					String[] urls = configs[i].split("=");
					service002Url = urls[1];
				}
				if (configs[i].indexOf("service002Param")>=0)
				{
					String[] params = configs[i].split("=");
					service002Param = params[1];
				}
			}
		}
	}
	
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/config/RestConsumerConfiguration.java

@@ -0,0 +1,17 @@
package com.ai.ipu.server.demo.config;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
@Configuration
public class RestConsumerConfiguration {
	@LoadBalanced
    @Bean
    public RestTemplate ipuRestTemplate() {
        return new RestTemplate();
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/nacos/SpringCloudConsumerController.java

@@ -0,0 +1,53 @@
package com.ai.ipu.server.demo.control.nacos;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import com.ai.ipu.server.demo.config.NacosConfig;
import com.alibaba.nacos.api.exception.NacosException;
import com.google.common.collect.Maps;
@RestController
@RefreshScope
@RequestMapping("/nacos/discovery/restConsumer")
public class SpringCloudConsumerController {
	private static final Logger logger = LoggerFactory.getLogger(SpringCloudConsumerController.class);
    @Autowired
    private RestTemplate restTemplate;
    
    @Value("${spring.application.name}")
    private String appName;
    
    @Autowired
	NacosConfig config;
    
	@ResponseBody
    @GetMapping(value = "/service002")
    public String service002() throws NacosException {
		
		try {
			/*用于ipu-spring-plumlog
			Map<String, Object> variables = Maps.newHashMap();
			variables.put("message", appName);*/
			return restTemplate.getForObject("http://ipu-nacos-cloud-provider" + config.getService002Url() + "?message=" + appName , String.class);
		} catch (Exception e) {
			logger.error(e.getMessage());
		}
		
        return null;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/service/demo/IBizService.java

@@ -1,33 +0,0 @@
package com.ai.ipu.service.demo;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年10月23日下午7:25:11
 * @desc 业务服务调用案例
 */
public interface IBizService {
    
    /**
     * @author huangbo@asiainfo.com
     * @title: queryUserInfo
     * @desc: 查询用户信息
     */
    public IData queryUserInfo(IData param);
    
    /**
     * @author huangbo@asiainfo.com
     * @title: queryUserInfo
     * @desc: 查询用户列表
     */
    public IData queryUserList(IData param);
    
    /**
     * @author huangbo@asiainfo.com
     * @title: triggerException
     * @desc: 触发业务异常
     */
    public IData triggerException(IData param);
}

ipu-rest-demo/src/main/resources/dev/application.properties

@@ -49,12 +49,18 @@ management.security.enabled=false
#spring.devtools.restart.additional-paths=src/main/java
#spring.devtools.restart.exclude=WEB-INF/**
#使用zookeeper当注册中心
spring.main.allow-bean-definition-overriding=true
dubbo.application.name=dubbo_consumer
dubbo.protocol.name=dubbo
#dubbo.application.name=dubbo_consumer
#dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.consumer.check=false
dubbo.registry.check=false
dubbo.registry.address=zookeeper://47.105.160.21:2108
dubbo.registry.client=curator
#dubbo.registry.check=false
#dubbo.registry.address=zookeeper://47.105.160.21:2108
#dubbo.registry.client=curator
#使用nacos当注册中心
dubbo.application.name=dubbo_consumer
dubbo.registry.address=nacos://47.105.160.21:8849
dubbo.protocol.name=dubbo

ipu-rest-demo/src/main/resources/dev/bootstrap.properties

@@ -0,0 +1,11 @@
spring.cloud.nacos.config.server-addr=47.105.160.21:8849
spring.cloud.nacos.config.prefix=example
spring.cloud.nacos.config.file-extension=properties
spring.cloud.nacos.config.group=DEFAULT_GROUP
spring.cloud.nacos.dataid=example
spring.cloud.nacos.group=DEFAULT_GROUP
spring.cloud.nacos.timeout=10000
spring.cloud.nacos.namespace
spring.cloud.nacos.discovery.server-addr=47.105.160.21:8849

ipu-rest-demo/src/main/resources/sql/com/ai/ipu/ipu-db-demo.xml

@@ -7,7 +7,13 @@
		</select>
		]]>
	</sql>
	
	<sql name="delete">
		<![CDATA[
		<select id="delete" resultType="java.util.Map">
	        DELETE FROM  ipu_db_demo WHERE pk=#{pk}
		</select>
		]]>
	</sql>
	<sql name="insert">
		<![CDATA[
		<insert id="insert" resultType="java.util.Map">