SpringCloud-服务注册与发现
这里我们会用到Spring Cloud Netflix,该项目是Spring Cloud的子项目之一,主要内容是对Netflix公司一系列开源产品的包装,它为Spring Boot应用提供了自配置的Netflix OSS整合。通过一些简单的注解,开发者就可以快速的在应用中配置一下常用模块并构建庞大的分布式系统。它主要提供的模块包括:服务发现(Eureka),断路器(Hystrix),智能路有(Zuul),客户端负载均衡(Ribbon)等。
所以,我们这里的核心内容就是服务发现模块:Eureka。下面我们动手来做一些尝试。
创建“服务注册中心”
创建一个基础的Spring Boot工程,并在pom.xml
中引入需要的依赖内容:
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency> <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies> <dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.BUILD-SNAPSHOT</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
通过@EnableEurekaServer
注解启动一个服务注册中心提供给其他应用进行对话。这一步非常的简单,只需要在一个普通的Spring Boot应用中添加这个注解就能开启此功能,比如下面的例子:
@EnableEurekaServer
@SpringBootApplication
public class Application {
public static void main(String[] args) {
new SpringApplicationBuilder(Application.class).web(true).run(args);
}
}
在默认设置下,该服务注册中心也会将自己作为客户端来尝试注册它自己,所以我们需要禁用它的客户端注册行为,只需要在application.properties
中问增加如下配置:
server.port=1111
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.client.serviceUrl.defaultZone=http://localhost:${server.port}/eureka/
为了与后续要进行注册的服务区分,这里将服务注册中心的端口通过server.port
属性设置为1111
。
启动工程后,访问:http://localhost:1111/
可以看到页面,其中还没有发现任何服务
创建“服务提供方”
下面我们创建提供服务的客户端,并向服务注册中心注册自己。
假设我们有一个提供计算功能的微服务模块,我们实现一个RESTful API,通过传入两个参数a和b,最后返回a + b的结果。
首先,创建一个基本的Spring Boot应用,在pom.xml
中,加入如下配置
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency> <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies> <dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.BUILD-SNAPSHOT</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
其次,实现/add
请求处理接口,通过DiscoveryClient
对象,在日志中打印出服务实例的相关内容。
@RestController
public class ComputeController {
private final Logger logger = Logger.getLogger(getClass());
@Autowired
private DiscoveryClient client;
@RequestMapping(value = "/add" ,method = RequestMethod.GET)
public Integer add(@RequestParam Integer a, @RequestParam Integer b) {
ServiceInstance instance = client.getLocalServiceInstance();
Integer r = a + b;
logger.info("/add, host:" + instance.getHost() + ", service_id:" + instance.getServiceId() + ", result:" + r);
return r;
}
}
最后在主类中通过加上@EnableDiscoveryClient
注解,该注解能激活Eureka中的DiscoveryClient
实现,才能实现Controller中对服务信息的输出。
@EnableDiscoveryClient
@SpringBootApplication
public class ComputeServiceApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(ComputeServiceApplication.class).web(true).run(args);
}
}
我们在完成了服务内容的实现之后,再继续对application.properties
做一些配置工作,具体如下:
spring.application.name=compute-service
server.port=2222
eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
通过spring.application.name
属性,我们可以指定微服务的名称后续在调用的时候只需要使用该名称就可以进行服务的访问。
eureka.client.serviceUrl.defaultZone
属性对应服务注册中心的配置内容,指定服务注册中心的位置。
为了在本机上测试区分服务提供方和服务注册中心,使用server.port
属性设置不同的端口。
启动该工程后,再次访问:http://localhost:1111/
可以看到,我们定义的服务被注册了。
最新文章
- 探索ASP.NET MVC5系列之~~~5.缓存篇(页面缓存+二级缓存)
- vs2013给项目统一配置boost库
- dll学习
- 最近学习linux命令的一个总结
- Web Workers 的基本信息
- ajx技术解析以及模拟jQuery封装
- UWP开发入门(十九)——10分钟学会在VS2015中使用Git
- cocos基础教程(5)数据结构介绍之cocos2d::Vector
- spark新能优化之序列化的持久化级别
- 延迟加载 ERROR org.hibernate.LazyInitializationException:42 - could not initialize proxy - ...
- 物联网MQTT协议分析和开源Mosquitto部署验证
- VS2015如何新建C++或者C语言版的lib文件
- pandas 获取数据帧DataFrame的行、列数
- java 中的引用数据类型
- 转:2016年崛起的js项目
- reorder-list 单链表
- linux报错jar包时出现“Exception in thread ";main"; java.lang.SecurityException: Invalid signature file digest for Manifest main attributes”
- BZOJ4003 JLOI2015城池攻占
- MySQL备份与还原详细过程示例
- ElasticSearch Aggs的一些使用方法
热门文章
- SpringMVC杂记(1) 使用阿里巴巴的fastjson
- Flex入门(一)——基本理论
- Junit初级篇
- 8)Linux程序设计入门--线程操作
- django:MySQL Strict Mode is not set for database connection &#39;default&#39;
- JS 与Flex交互:html中的js 与flex中的actionScript通信
- MonoSingleton——Unity中的单例模式
- [Python爬虫] 之四:Selenium 抓取微博数据
- 微信公众帐号开发教程第4篇-----开发模式启用及接口配置Java
- ACCESS数据库如何设置密码