专栏首页品茗ITSpringCloud技术指南系列(三)服务注册发现之Eureka服务调用

SpringCloud技术指南系列(三)服务注册发现之Eureka服务调用

SpringCloud技术指南系列(三)服务注册发现之Eureka服务调用

SpringCloud所谓的服务注册与发现,流程大致是:

  • 将Springboot微服务客户端项目的地址等信息,通过网络发送到注册中心,由注册中心保存下来。
  • 另一个客户端B访问已经注册到注册中心的服务A,通过注册中心提供的域名解析方式,解析出服务A的地址等信息。
  • 如果提供服务A的客户端有多个,就按照某个策略(比如轮询、负载均衡等)选取一个地址返回。
  • 客户端B访问注册中心返回的地址,获取结果,这里注意,是B直接访问A,而不是注册中心转发,因此要保证B和A是互通的。

目前服务发现的解决方案有Eureka,Consul,Zookeeper等,这三个是SpringCloud官方支持的。

前面已经讲了如何搭建Eureka的注册中心和服务注册,本篇讲下Eureka的服务发现,使用两种方式进行服务发现。

代码可以在SpringBoot组件化构建https://www.pomit.cn/java/spring/springcloud.html中的EurekaClient和EurekaFeign组件中查看,并下载。

**如果大家正在寻找一个java的学习环境,或者在开发中遇到困难,可以<a

href="https://jq.qq.com/?_wv=1027&k=52sgH1J"

target="_blank">

加入我们的java学习圈,点击即可加入

</a>

,共同学习,节约学习时间,减少很多在学习中遇到的难题。**

一、引入依赖

需要引入spring-boot-starter-web和spring-cloud-starter-netflix-eureka-client,因为要进行服务调用,所以要引入spring-cloud-starter-netflix-ribbon,如果要使用openfeign来进行服务调用,则可以引入spring-cloud-starter-openfeign。

依赖如下:

<?xml version="1.0"?>
<project
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
	xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>cn.pomit</groupId>
		<artifactId>springcloudwork</artifactId>
		<version>0.0.1-SNAPSHOT</version>
	</parent>
	<artifactId>EurekaClient</artifactId>
	<name>EurekaClient</name>
	<url>http://maven.apache.org</url>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
		<maven-jar-plugin.version>2.6</maven-jar-plugin.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
		</dependency>

		<!-- 使用ribbon时才用的上 -->
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
		</dependency>

                <!-- 使用feign时才用的上 -->
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-openfeign</artifactId>
		</dependency>
	</dependencies>
</project>

父模块pom文件可以在https://www.pomit.cn/spring/SpringCloudWork/pom.xml获取。

二、配置eureka服务注册

这里使用yaml文件写配置,application.yml:

server:
  port: 8810
spring:
  application:
    name: eurekaClient
eureka:
  instance:
    hostname: localhost
    prefer-ip-address: true
  client:
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:8888/eureka/

这里面,包含了端口、应用名、注册信息、方式。

spring.application.name是标识了应用名,注册到eureka之后,显示的就是它。

eureka.instance.prefer-ip-address是使用ip地址,如果不写它,默认是域名,那样测试起来很麻烦。

eureka.client.serviceUrl这个,是配置将本服务注册为客户端,这里注册到http://localhost:8888/eureka/。

注意这里的url里有/eureka,这个后缀,而访问注册中心的时候用的是http://localhost:8888。

三、启动服务注册发现

3.1 启动类

使用@EnableEurekaClient和@EnableDiscoveryClient注解启动类, @EnableEurekaClient是将项目作为客户端注册到注册中心的注解,@EnableDiscoveryClient开启服务发现功能。使用Eureka做服务发现,要加上这两个注解。

如果是使用Feign,需要加上@EnableFeignClients注解,开启Feign的使用

EurekaClientApplication:

package cn.pomit.springbootwork.eurekaclient;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

//@EnableFeignClients
@EnableEurekaClient
@EnableDiscoveryClient
@SpringBootApplication
public class EurekaClientApplication {
	public static void main(String[] args) {
		SpringApplication.run(EurekaClientApplication.class, args);
	}

	@Bean
	@LoadBalanced
	RestTemplate restTemplate() {
		return new RestTemplate();
	}
}

这里的RestTemplate使用@LoadBalanced注解,我们跟踪RestTemplate的时候可以看到,RestTemplate多了个LoadBalancerInterceptor。

3.2 Ribbon做服务调用

如果我们使用Ribbon做服务调用,需要使用RestTemplate,这个RestTemplate是标识为负载均衡的。我们来调用上一篇提供的ip服务:

IpInfoService :

package cn.pomit.springbootwork.eurekaclient.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import cn.pomit.springbootwork.eurekaclient.model.ResultModel;

@Service
public class IpInfoService {
	/**
	 * 第一个EUREKASERVER是服务提供方配置文件种的spring.application.name,第二个eurekaServer是服务提供方的controller中配置的路径
	 */
	public static String remoteIpServiceUrl = "http://EUREKASERVER/eurekaServer/ip";
	@Autowired
	private RestTemplate restTemplate;

	public ResultModel getIpInfo() {
		ResponseEntity<ResultModel> ipModel = restTemplate.getForEntity(remoteIpServiceUrl, ResultModel.class);
		return ipModel.getBody();
	}
}

这里,第一个EUREKASERVER是服务提供方配置文件种的spring.application.name,第二个eurekaServer是服务提供方的controller中配置的路径。我们使用统一的实体ResultModel进行数据接收转换。

3.3 Feign做服务调用

如果我们使用Feign做服务调用,写法就和controller中写法类似,需要注意的是,如果带参数,需要使用@RequestParam("")标识参数名 :

IpInfoService :

package cn.pomit.springbootwork.eurekafeign.service;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import cn.pomit.springbootwork.eurekafeign.model.ResultModel;

@FeignClient("EUREKASERVER")
public interface IpInfoService {
	@RequestMapping(method = RequestMethod.GET, value = "/eurekaServer/ip", consumes = "application/json")
	public ResultModel getIpInfo();
}

这里,@FeignClient中的EUREKASERVER是服务提供方配置文件种的spring.application.name,/eurekaServer/ip中的eurekaServer是服务提供方的controller中配置的路径。方法尽量和服务提供方的方法一样。

3.4 测试Web

package cn.pomit.springbootwork.eurekaclient.web;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import cn.pomit.springbootwork.eurekaclient.model.ResultModel;
import cn.pomit.springbootwork.eurekaclient.service.IpInfoService;

@RestController
@RequestMapping("/eurekaClient")
public class EurekaClientRest {
	@Autowired
	IpInfoService ipInfoService;

	@RequestMapping(value = "/test", method = { RequestMethod.GET })
	public String test() {
		return "Hello, Hello";
	}

	@RequestMapping(value = "/ip", method = { RequestMethod.GET })
	public ResultModel ip() {
		return ipInfoService.getIpInfo();
	}
}

四、过程中用到的实体

过程中用到了ResultModel实体和ResultCode枚举类,是和上一篇中的实体对应的,作为统一的实体来用。

ResultModel:

package cn.pomit.springbootwork.eurekaclient.model;

/**
 * @author cff
 */
public class ResultModel {

	private String errorCode;
	private String message;
	private Object data;

	public ResultModel() {

	}

	public ResultModel(String errorCode, String message) {
		this.errorCode = errorCode;
		this.message = message;
	}

	public ResultModel(String errorCode, String message, Object data) {
		this.errorCode = errorCode;
		this.message = message;
		this.data = data;
	}

	public ResultModel(ResultCode resultCodeEnum, Object data) {
		this.errorCode = resultCodeEnum.getCode();
		this.message = resultCodeEnum.getDesc();
		this.data = data;
	}

	public ResultModel(ResultCode resultCodeEnum) {
		this.errorCode = resultCodeEnum.getCode();
		this.message = resultCodeEnum.getDesc();
	}

	public String geterrorCode() {
		return errorCode;
	}

	public void seterrorCode(String errorCode) {
		this.errorCode = errorCode;
	}

	public String getMessage() {
		return message;
	}

	public void setMessage(String message) {
		this.message = message;
	}

	public Object getData() {
		return data;
	}

	public void setData(Object data) {
		this.data = data;
	}

	public static ResultModel ok() {
		return new ResultModel(ResultCode.CODE_00000);
	}

	public static ResultModel ok(Object data) {
		return new ResultModel(ResultCode.CODE_00000, data);
	}

	public static ResultModel error() {
		return new ResultModel(ResultCode.CODE_00001);
	}

	public static ResultModel error(String msg) {
		return new ResultModel(ResultCode.CODE_00001.getCode(), msg);
	}

	public static ResultModel error(String msg, Object data) {
		return new ResultModel(ResultCode.CODE_00001.getCode(), msg, data);
	}

	public static ResultModel unAuth() {
		return new ResultModel(ResultCode.CODE_40004);
	}
}

ResultCode:

package cn.pomit.springbootwork.eurekaclient.model;

/**
 * 响应码及其描述 Created by txl on 15/7/9.
 */
public enum ResultCode {

	/**
	 * 通用
	 */
	CODE_00000("00000", "操作成功"), CODE_00001("00001", "请求失败"), CODE_00002("00002", "错误的请求方法"), CODE_00003("00003", "非法的参数字段"), CODE_00004("00004", "异常抛出"), CODE_00005("00005", "权限不足"), CODE_00006("00006", "分页limit参数错误"), CODE_00007("00007", "分页offset参数错误"), CODE_00009("00009", "请求过于频繁"), CODE_00010("00010", "数据已存在"), CODE_00011("00011", "数据不存在"), CODE_00012("00012", "参数缺失"), CODE_00013("00013", "系统维护中"), CODE_00014("00014", "token缺失"), CODE_00015("00015", "token失效"), CODE_00016("00016", "签名错误"),

	CODE_10000("10000", "操作部分成功"),
	/**
	 * 系统
	 */
	CODE_30000("30000", "系统ID错误"),

	/**
	 * 授权
	 */
	CODE_40001("40001", "用户未找到"), CODE_40002("40002", "该用户状态异常"), CODE_40003("40003", "该用户已被删除"), CODE_40004("40004", "授权异常"),

	CODE_99999("99999", "签名无效");

	private String code;
	private String desc;

	ResultCode(String code, String desc) {
		this.code = code;
		this.desc = desc;
	}

	public String getCode() {
		return code;
	}

	public String getDesc() {
		return desc;
	}

	/**
	 * 根据code匹配枚举
	 * 
	 * @param code
	 * @return
	 */
	public static ResultCode getResultCodeByCode(String code) {
		for (ResultCode resultCode : ResultCode.values()) {
			if (code.equals(resultCode.getCode())) {
				return resultCode;
			}
		}
		return null;
	}

	public static ResultCode getResultCodeByDesc(String desc) {
		for (ResultCode resultCode : ResultCode.values()) {
			if (desc.equals(resultCode.getDesc())) {
				return resultCode;
			}
		}
		return null;
	}
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 《你不知道的JavaScript》:迭代器Iterator的背景梳理

    本篇复习下上篇用到的Symbol.iterator,它是ES6内置的十一个Symbol值之一。ES6中规定对象的Symbol.iterator属性指向该对象的默...

    前端_AWhile
  • 《你不知道的JavaScript》:生成器中的生产者和迭代器

    生成器的一种有趣用法是作为一种产生值的方式。而这也是“生成器”这个名称的最初使用场景。前面说过生成器函数每次调用都会创建一个迭代器实例。这个迭代器实例有next...

    前端_AWhile
  • 解Bug之路-dubbo流量上线时的非平滑问题

    笔者最近解决了一个困扰了业务系统很久的问题。这个问题只在发布时出现,每次只影响一两次调用,相较于其它的问题来说,这个问题有点不够受重视。由于种种原因,使得这个问...

    无毁的湖光-Al
  • Synchronized 和 Lock 的区别和使用场景

    并发编程中,锁是经常需要用到的,今天我们一起来看下Java中的锁机制:synchronized和lock。

    cxuan
  • 《你不知道的JavaScript》:利用生成器实现消息传递

    js中生成器函数是一个特殊的函数,具有上一篇中展示出来的“暂停”的执行模式。但它仍然是一个函数,这意味着它仍然有一些基本的特性没有改变。例如它仍然可以接收参数(...

    前端_AWhile
  • 详细解读 Prometheus 的指标类型

    原文链接:https://prometheus.io/docs/concepts/metric_types/

    米开朗基杨
  • 《你不知道的JavaScript》:弄清生成器与迭代器的区别

    这篇将整理下生成器与迭代器的区别。这两个东西初学的时候我是混淆的,尤其《你不知道的Javascript》书中没有进行基础的介绍,我看了之后还特地翻了下其他资料才...

    前端_AWhile
  • ES6中的Class回顾总结三:封装与多态

    在Java中,实现了public完全开放、protected对子类开放、private对自己开放这三种封装的方式。但在ES6中目前并不支持,未来是否会支持也不知...

    前端_AWhile
  • Netty自动重连机制的Demo

    官方案例地址:https://netty.io/4.1/xref/io/netty/example/uptime/package-summary.html

    Java猫说
  • 你确定你会写 Dockerfile 吗?

    如今 GitHub 仓库中已经包含了成千上万的 Dockerfile,但并不是所有的 Dockerfile 都是高效的。本文将从五个方面来介绍 Dockerfi...

    米开朗基杨

扫码关注云+社区

领取腾讯云代金券