Nacos的服务注册和服务调用范例，目前支持URL拼接形式的调用

ipu-nacos-demo/pom.xml

@@ -43,14 +43,14 @@
	</repositories>
	<properties>
		<start-class>com.ai.ipu.server.IpuNacosDemoStart</start-class>
		<start-class>com.ai.ipu.server.NacosDemoStart</start-class>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<mongo.java.driver>3.11.2</mongo.java.driver>
		<ipu>3.1-SNAPSHOT</ipu>
		<jdk>1.8</jdk>
		<junit>4.12</junit>
		<spring-session.version>1.3.2.RELEASE</spring-session.version>
		<nacos>0.1.1</nacos>
		<nacos>0.1.7</nacos>
	</properties>
	<dependencies>
@@ -71,17 +71,12 @@
			<groupId>com.alibaba.boot</groupId>
			<artifactId>nacos-config-spring-boot-starter</artifactId>
			<version>${nacos}</version>
			<exclusions>
				<exclusion>
					<groupId>com.alibaba.nacos</groupId>
					<artifactId>nacos-client</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<!-- 引入nacos服务注册中心 -->
		<dependency>
			<groupId>com.alibaba.nacos</groupId>
			<artifactId>nacos-client</artifactId>
			<version>0.6.2</version>
			<groupId>com.alibaba.boot</groupId>
			<artifactId>nacos-discovery-spring-boot-starter</artifactId>
			<version>${nacos}</version>
		</dependency>
	</dependencies>

ipu-nacos-demo/src/main/java/com/ai/ipu/server/IpuNacosDemoStart.java

@@ -7,7 +7,7 @@ import com.ai.ipu.restful.boot.IpuRestApplication;
 * @date 2019年11月21日下午3:11:12
 * @desc SpringBoot应用启动类
 */
public class IpuNacosDemoStart {
public class NacosDemoStart {
	public static void main(String[] args) {
		/*启动*/

ipu-nacos-demo/src/main/java/com/ai/ipu/server/config/NacosServiceRegistry.java

@@ -0,0 +1,35 @@
package com.ai.ipu.server.config;
import javax.annotation.PostConstruct;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import com.ai.ipu.server.util.IpUtil;
import com.alibaba.nacos.api.annotation.NacosInjected;
import com.alibaba.nacos.api.naming.NamingService;
@Configuration
public class NacosServiceRegistry {
    private static final Logger log = LoggerFactory.getLogger(NacosServiceRegistry.class);
    @Value("${server.port}")
    private int serverPort;
    @Value("${spring.application.name}")
    private String appName;
    @NacosInjected
    private NamingService namingService;
    @PostConstruct
    public void registerService() {
        try {
            // Nacos服务自动注册，有多块网卡时，取不是.1结尾并且IP地址排序最小的做为当前IP
            namingService.registerInstance(appName, IpUtil.getHostAddress(), serverPort, "DEFAULT");
        } catch (Exception e) {
            log.error(e.getMessage());
        }
    }
}

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

@@ -0,0 +1,49 @@
package com.ai.ipu.server.control;
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.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.client.RestTemplate;
import com.alibaba.nacos.api.annotation.NacosInjected;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
@Controller
@RequestMapping("/nacos/consumer")
public class NacosConsumerControl {
    private static final Logger logger = LoggerFactory.getLogger(NacosConsumerControl.class);
    
    @Value("${spring.application.name}")
    private String appName;
    
    @NacosInjected
    private NamingService namingService;
    
    private RestTemplate restTemplate = new RestTemplate();
    
    @ResponseBody
    @RequestMapping(value = "/hello")
    public String hello() throws NacosException {
        String msg = "Hello World";
        // 选择服务的一个健康实例(可配置负载均衡策略)
        Instance instance = namingService.selectOneHealthyInstance(appName);
        // 拼接请求接口url并请求选取的实例
        StringBuilder buff = new StringBuilder();
        buff.append("http://");
        buff.append(instance.getIp()).append(":").append(instance.getPort());
        buff.append("/ipu/nacos/provider/hello?message=").append(msg);
        String url = buff.toString();
        
        logger.debug(String.format("请求URL:%s", url));
        ResponseEntity<String> entity = restTemplate.getForEntity(url, String.class);
        logger.debug(String.format("响应结果:%s", entity.getBody()));
        return entity.getBody();
    }
}

ipu-nacos-demo/src/main/java/com/ai/ipu/server/service/NacosProviderControl.java

@@ -0,0 +1,18 @@
package com.ai.ipu.server.service;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
@RequestMapping("/nacos/provider")
public class NacosProviderControl {
    @ResponseBody
    @GetMapping(value = "/hello")
    public String hello(String message) {
        return "Nacos：" + message;
    }
    
}

ipu-nacos-demo/src/main/java/com/ai/ipu/server/util/IpUtil.java

@@ -0,0 +1,58 @@
package com.ai.ipu.server.util;
import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
import java.util.List;
/**
 * 地址工具类
 * 
 * @author Administrator
 *
 */
public class IpUtil {
	private static String hostAddress = null;
	
	/**
	 * 获取本机ip地址<BR/>
	 * 不会将.1结尾的ip作为合法地址</BR>
	 * 如果有多块网卡，将返回地址最小的那个<BR/>
	 * 可以在程序启动入口参数中指定本机地址
	 * 
	 * @return
	 * @throws SocketException
	 */
	public static String getHostAddress() throws SocketException {
		if(hostAddress!=null){
			return hostAddress;
		}
		
		InetAddress ip = null;
		List<String> addressList = new ArrayList<String>();
		Enumeration<NetworkInterface> allNetInterfaces = NetworkInterface.getNetworkInterfaces();
		while (allNetInterfaces.hasMoreElements())
		{
			NetworkInterface netInterface = (NetworkInterface) allNetInterfaces.nextElement();
			Enumeration<InetAddress> addresses = netInterface.getInetAddresses();
			while (addresses.hasMoreElements())
			{
				ip = (InetAddress) addresses.nextElement();
				if (ip != null && ip instanceof Inet4Address)
				{
					if (!ip.getHostAddress().endsWith(".1"))
							addressList.add(ip.getHostAddress());
				} 
			}
		}
		Collections.sort(addressList);
		hostAddress = (String)addressList.get(0);
		return hostAddress;
	}
	
}

ipu-nacos-demo/src/main/resources/ipu-spring-mvc.xml

@@ -11,7 +11,4 @@
		http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
    <context:component-scan base-package="com.ai.ipu.server" />
	<!-- <aop:aspectj-autoproxy proxy-target-class="true"/>
	<context:annotation-config />
	<bean id="transcationAspects" class="com.ai.ipu.nosql.aspect.TransactionAspect" /> -->
</beans>