SpringCloud搭建netflix-eureka微服务集群的过程详解
作者:追极 发布时间:2023-09-02 18:11:52
1.打开官网稍微学习一下,了解一下spring cloud是个什么东西,大概有哪些组件等
https://spring.io/projects/spring-cloud
https://docs.spring.io/spring-cloud-netflix/docs/current/reference/html/
2.新建项目
打开网址:https://start.spring.io/
选择需要引入的组件,然后下载下来即可
3.更改项目结构
为了测试的方便,需将项目结构更改为多模块的项目。
步骤如下:
(1) 依次新建子模块register-center/provider/consumer,删除父模块中多余的src、target等文件夹
(2) 修改父模块的pom文件:仅保留<dependencyManagement>配置节,<dependencies>配置节全部注释掉,因为可在子模块按需添加依赖。
(3) 修改register-center的pom中的依赖配置
<dependencies>
<!-- Eureka注册中心 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
(4) 修改provider和consumer的pom中依赖配置
<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>
</dependencies>
4.新建相应的测试类和配置文件
4.1 register-center模块
启动类
package com.hdwang.springcloudtest.registercenter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication
@EnableEurekaServer
public class Application {
/**
* 运行点对点模式(集群模式)时,通过添加VM参数启动不同的注册中心节点实例
* 例如:-Dspring.profiles.active=peer2
*
* @param args
*/
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
yml配置
spring:
application:
#应用名
name: register-center
freemarker:
template-loader-path: classpath:/templates/
prefer-file-system-access: false
#激活的配置,可运行时添加参数进行修改 -Dspring.profiles.active=peer2
profiles:
active: peer1
# #Eureka独立模式配置,仅有一个注册中心节点
#server:
# port: 8090
#eureka:
# instance:
# hostname: localhost
# client:
# #仅仅作为注册中心,既不提供服务也不订阅服务
# registerWithEureka: false
# fetchRegistry: false
# #注册中心地址
# serviceUrl:
# defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
# Eureka点对点模式,保证注册中心高可用,注册的实例信息会在点与点之间相互同步
eureka:
client:
serviceUrl:
defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/
---
#每个注册中心节点不同的配置
spring:
profiles: peer1
server:
port: 8091
eureka:
instance:
#在本机hosts中配置即可
hostname: peer1.com
---
spring:
profiles: peer2
server:
port: 8092
eureka:
instance:
hostname: peer2.com
---
spring:
profiles: peer3
server:
port: 8093
eureka:
instance:
hostname: peer3.com
4.2 provider模块
启动类
package com.hdwang.springcloudtest.provider;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application {
/**
* 运行时添加VM参数: -Dserver.port=8082可以启动多个provider实例
*
* @param args
*/
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
服务注册类
package com.hdwang.springcloudtest.provider.restservice;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* 注册的服务
*/
@RestController
public class RestService {
/**
* 日志
*/
private static final Logger LOG = LoggerFactory.getLogger(RestService.class);
@RequestMapping("/sayHello")
public String sayHello(String name) {
LOG.info("sayHello was called");
return "hello, " + name;
}
}
yml配置
spring:
application:
#应用名,也是eureka的服务名
name: provider
freemarker:
template-loader-path: classpath:/templates/
prefer-file-system-access: false
server:
#运行时,添加参数-Dserver.port=8082运行新的provider实例
port: 8081
eureka:
client:
#注册中心地址
serviceUrl:
#注册中心独立模式
#defaultZone: http://localhost:8090/eureka/
#注册中心点对点模式
defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/
4.3 consumer配置
启动类
package com.hdwang.springcloudtest.consumer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
服务调用测试类
package com.hdwang.springcloudtest.consumer.controller;
import com.netflix.appinfo.InstanceInfo;
import com.netflix.discovery.EurekaClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.util.*;
/**
* 测试
*/
@RestController
public class TestController {
/**
* 使用服务名才能负载均衡,不能使用直接使用地址
*/
private static final String REST_URL_PREFIX = "http://provider";
@Autowired
private EurekaClient discoveryClient;
@Autowired
private RestTemplate restTemplate;
@GetMapping("/testGet")
public String testGet() {
ResponseEntity<String> res = restTemplate.getForEntity(REST_URL_PREFIX + "/sayHello?name={1}", String.class, getName());
return res.getBody();
}
@GetMapping("/testPost")
public String testPost() {
MultiValueMap<String, Object> params = new LinkedMultiValueMap<String, Object>();
params.add("name", getName());
// HttpHeaders headers = new HttpHeaders();
// headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
HttpEntity< MultiValueMap<String, Object>> request = new HttpEntity<>(params, null);
ResponseEntity<String> res = restTemplate.postForEntity(REST_URL_PREFIX + "/sayHello", request, String.class);
return res.getBody();
}
private String getName() {
List<String> greetings = Arrays.asList("Bob", "Alice", "Jack");
Random rand = new Random();
int randomNum = rand.nextInt(greetings.size());
return greetings.get(randomNum);
}
}
RestTemplate负责均衡配置类
package com.hdwang.springcloudtest.consumer.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 RestTemplateConfig {
/**
* 构建有负载均衡功能的RestTemplate实例对象
*
* @return RestTemplate实例对象
*/
@Bean
@LoadBalanced
RestTemplate restTemplate() {
return new RestTemplate();
}
}
yml配置
spring:
application:
#应用名,也是Eureka的服务名
name: cosumer
server:
port: 8088
eureka:
client:
#注册中心地址
serviceUrl:
#注册中心独立模式
#defaultZone: http://localhost:8090/eureka/
#注册中心点对点模式
defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/
5.运行测试
5.1本机hosts配置
127.0.0.1 peer1.com
127.0.0.1 peer2.com
127.0.0.1 peer3.com
5.2 编辑运行配置
三个注册中心节点运行配置
两个服务提供者的运行配置
5.3 运行程序
(1) 启动注册中心
依次启动RegisterCenter1->RegisterCenter2->RegisterCenter3,启动成功后,可访问http://localhost:8091/ 或http://localhost:8092/ 或http://localhost:8093/ 查看是否启动成功
(2)启动服务提供者provider
依次启动Provider1->Provider2, 随便访问一个注册中心地址首页即可查看状态,如下图
(3) 启动消费者cosumer
(4) 在浏览器中进行测试
测试地址:http://localhost:8088/testPost / http://localhost:8088/testGet
(5) 在Provider1/Provider2的控制台中可以看到输出结果
2021-04-07 15:26:56.043 INFO 8796 --- [nio-8081-exec-1] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:26:58.860 INFO 8796 --- [nio-8081-exec-2] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:26:59.535 INFO 8796 --- [nio-8081-exec-3] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:26:59.925 INFO 8796 --- [nio-8081-exec-4] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:27:00.266 INFO 8796 --- [nio-8081-exec-5] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:27:00.663 INFO 8796 --- [nio-8081-exec-6] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:27:00.938 INFO 8796 --- [nio-8081-exec-7] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:26:58.602 INFO 17828 --- [nio-8082-exec-1] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:26:59.194 INFO 17828 --- [nio-8082-exec-2] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:26:59.737 INFO 17828 --- [nio-8082-exec-3] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:27:00.109 INFO 17828 --- [nio-8082-exec-4] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:27:00.414 INFO 17828 --- [nio-8082-exec-5] c.h.s.provider.restservice.RestService : sayHello was called
2021-04-07 15:27:00.815 INFO 17828 --- [nio-8082-exec-6] c.h.s.provider.restservice.RestService : sayHello was called
恭喜!至此,Spring Clound 微服务集群框架您已经搭建成功!
附录
github地址:https://github.com/hdwang123/springcloudtest
参考文章:
https://www.zhihu.com/question/283286745/answer/763040709
https://www.cnblogs.com/qdhxhz/p/9357502.html
https://www.cnblogs.com/cjsblog/p/8005766.html
https://blog.csdn.net/weixin_44448094/article/details/88535475
来源:https://www.cnblogs.com/hdwang/archive/2021/04/07/14628372.html
猜你喜欢
- Java程序有的时候在主线程中会创建多个线程去执行任务,然后在主线程执行完毕之前,把所有线程的任务进行汇总,以前可以用线程的join方法,但
- 简介Springboot Admin是一个管理和监控Springboot项目的组件,分为服务端和客户端,两端通过http进行通信。由于其轻量
- timer和timertask是jdk自带的定时任务实现,无需导入第三方jar包来完成1、指定多久之后执行此任务,注意:只会执行一次publ
- 解决方法有如下两种:第一种如果你 repo sync 了 android 的整个源码,那么可以直接把你的 app 放到 /packages/
- 本文实例讲述了Java继承Thread类创建线程类。分享给大家供大家参考,具体如下:一 点睛通过继承Thread类创建线程并启动多线程的步骤
- 最近没事写了一个简易浏览器,在刚开始写的时候遇到一些问题,主要的问题就是如何在自己的webview中显示所有的网页数据,不过不指
- 半路开始看的朋友可以回顾一下前几篇java并发编程专题(一)----线程基础知识java并发编程专题(二)----如何创建并运行java线程
- Eureka注册的服务之间互相调用1.请求方启动类添加注解,扫描Eureka 中的全部服务@SpringBootApplication@En
- //构造文件File类File f=new File(fileName);//判断是否为目录f.isDirectory();//获取目录下的
- 字段策略 0:”忽略判断”,1:”非 NULL 判断”),2:”非空判断”问题描述:当字段策略为 0 “忽略判断” 的时候,如果实体和数据库
- 本文实例讲述了Java实现接口的枚举类。分享给大家供大家参考,具体如下:一 点睛枚举类也可以实现一个或多个接口。与普通类实现一个或多个接口完
- C#串口模块的使用。使用VS .net框架下WinForm程序应用开发。C#开发的串口通信小工具。相比于QT添加的串口类,WinForm是通
- 我们通过学习Java基础知识,让自己正式踏入学习Java语言的行列,这篇博客是用来让我们真正的了解并应用面向对象的思想来实现的。使用简单的J
- logback输出日志屏蔽quartz的debug等级日志在一个spring的老项目中,使用了logback来作为日志管理,logback.
- 目前很多业务使用微服务架构,服务模块划分有这2种方式:服务功能划分业务划分不管哪种方式,一次接口调用都需要多个服务协同完成,其中一个服务出现
- 前言我们在学习Windows应用程序开发中,经常会用到消息对话框给用户或者管理员一些的消息提示,它们都是基于对MessageBox类的消息对
- 方法参数public String listFireEvent(@Valid FireSearch fireSearch, Ht
- 首先当我们将Dwr3配置好以后,我们可以在浏览器中测试一下,查看一下我们配置的Dwr有没有生效,方法是http://localhost:[你
- 本篇实例内容是关于C#读取CAD文件的,直接看代码//在不使用任务插件的情况下读取DWG文件的缩略图,以便在没有安装AutoCAD的计算机上
- wait(), notify(), notifyAll()等方法介绍在Object.java中,定义了wait(), notify()和no