摘要:接收参数对象添加用户微服务启动类用户服务类添加服务注册,将用户微服务注册到中。
SpringCloud(第 004 篇)用户服务类(添加服务注册,将用户微服务注册到 EurekaServer 中)
-
一、大致介绍通过添加注解 EnableEurekaClient,将用户微服务注册到 EurekaServer 中。二、实现步骤 2.1 添加 maven 引用包
2.2 添加应用配置文件(springms-provider-usersrcmainresourcesapplication.yml)4.0.0 springms-provider-user 1.0-SNAPSHOT jar com.springms.cloud springms-spring-cloud 1.0-SNAPSHOT org.springframework.boot spring-boot-starter-data-jpa org.springframework.boot spring-boot-starter-web com.h2database h2 runtime org.springframework.cloud spring-cloud-starter-eureka org.springframework.boot spring-boot-starter-actuator
server: port: 7900 spring: jpa: generate-ddl: false show-sql: true hibernate: ddl-auto: none datasource: platform: h2 schema: classpath:schema.sql data: classpath:data.sql application: name: springms-provider-user #全部小写 logging: level: root: INFO org.hibernate: INFO org.hibernate.type.descriptor.sql.BasicBinder: TRACE org.bibernate.type.descriptor.sql.BasicExtractor: TRACE com.springms: DEBUG eureka: client: service-url: # defaultZone: http://localhost:8761/eureka/ #不需要认证 defaultZone: http://admin:admin@localhost:8761/eureka #需要认证 instance: prefer-ip-address: true instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}} # 元数据测试 metadata-map: zone: ABC # eureka 可以理解的元数据 hmily: HMILYYLIMH # 不会影响客户端行为 # appname: appname-springms-provider-user # 直接显示的是App应用的名称,在 http://localhost:8761/ 地址处可以看到该注册服务的应用名称 # # 这里我们就先注释掉,知道这个 hostname 的用法就可以了,先注释掉不影响后面的测试 # hostname: user # 然后我们就可以通过 http://user:7900/simple/1 来访问我们的地址了2.3 添加 H2 数据库脚本(springms-provider-usersrcmainresourcesschema.sql)
drop table user if exists; CREATE TABLE USER( id BIGINT GENERATED by default as identity, username VARCHAR(40), name VARCHAR(20), age int(3), balance DECIMAL(10, 2), PRIMARY KEY(id) );2.4 插入 H2 数据库一些初始化数据(springms-provider-usersrcmainresourcesdata.sql)
INSERT into user (id, username, name, age, balance) values (1, "user1", "张三", 20, 100.00); INSERT into user (id, username, name, age, balance) values (2, "user2", "李四", 22, 100.00); INSERT into user (id, username, name, age, balance) values (3, "user3", "王五", 24, 100.00); INSERT into user (id, username, name, age, balance) values (4, "user4", "赵六", 26, 100.00); INSERT into user (id, username, name, age, balance) values (5, "user5", "李逵", 27, 100.00); INSERT into user (id, username, name, age, balance) values (6, "user6", "张远", 10, 100.00); INSERT into user (id, username, name, age, balance) values (7, "user7", "迪拜", 60, 100.00); INSERT into user (id, username, name, age, balance) values (8, "user8", "哈士奇", 40, 100.00); INSERT into user (id, username, name, age, balance) values (9, "user9", "关羽", 30, 100.00);2.5 添加访问底层数据模型的DAO接口(springms-provider-usersrcmainjavacomspringmscloudrepositoryUserRepository.java)
package com.springms.cloud.repository; import com.springms.cloud.entity.User; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.stereotype.Repository; @Repository public interface UserRepository extends JpaRepository2.6 添加实体用户类User(springms-provider-usersrcmainjavacomspringmscloudentityUser.java){ }
package com.springms.cloud.entity; import java.math.BigDecimal; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; @Entity public class User { @Id @GeneratedValue(strategy = GenerationType.AUTO) private Long id; @Column private String username; @Column private String name; @Column private Short age; @Column private BigDecimal balance; public Long getId() { return this.id; } public void setId(Long id) { this.id = id; } public String getUsername() { return this.username; } public void setUsername(String username) { this.username = username; } public String getName() { return this.name; } public void setName(String name) { this.name = name; } public Short getAge() { return this.age; } public void setAge(Short age) { this.age = age; } public BigDecimal getBalance() { return this.balance; } public void setBalance(BigDecimal balance) { this.balance = balance; } }2.7 添加用户Web访问层Controller(springms-provider-usersrcmainjavacomspringmscloudcontrollerUserController.java)
package com.springms.cloud.controller; import com.google.common.collect.Lists; import com.springms.cloud.entity.User; import com.springms.cloud.repository.UserRepository; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import java.util.ArrayList; import java.util.List; /** * 用户界面控制层。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017/9/17 * */ @RestController public class UserController { @Autowired private UserRepository userRepository; // @Autowired // private EurekaClient discoveryClient; @GetMapping("/simple/{id}") public User findById(@PathVariable Long id){ return userRepository.findOne(id); } // public String serviceUrl(){ // InstanceInfo instance = this.discoveryClient.getNextServerFromEureka("SPRINGMS-PROVIDER-USER", false); // return instance.getHomePageUrl(); // } @PostMapping("/user") public User postUser(@RequestBody User user){ System.out.println("@GetMapping("user") 接收参数对象 user: " + user); return user; } @GetMapping("listAll") public List2.8 添加用户微服务启动类(springms-provider-usersrcmainjavacomspringmscloudMsProviderUserApplication.java)listAll(){ ArrayList list = Lists.newArrayList(); User user1 = new User(1L, "user1"); User user2 = new User(1L, "user2"); User user3 = new User(1L, "user3"); User user4 = new User(1L, "user4"); User user5 = new User(1L, "user5"); list.add(user1); list.add(user2); list.add(user3); list.add(user4); list.add(user5); return list; } }
package com.springms.cloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; /** * 用户服务类(添加服务注册,将用户微服务注册到 EurekaServer 中)。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017/9/17 * */ @SpringBootApplication @EnableEurekaClient public class MsProviderUserApplication { public static void main(String[] args) { SpringApplication.run(MsProviderUserApplication.class); System.out.println("【【【【【【 用户微服务 】】】】】】已启动."); } }三、测试
/**************************************************************************************** 一、用户微服务接口测试: 1、注解:EnableEurekaClient 2、启动 springms-discovery-eureka 模块服务,启动1个端口; 3、启动 springms-provider-user 模块服务,启动1个端口; 4、在浏览器输入地址http://localhost:7900/simple/1 可以看到信息成功的被打印出来,说明用户微服务正常; 5、在浏览器输入地址 http://localhost:8761 并输入用户名密码 admin/admin 进入Eureka微服务显示在网页中,说明用户微服务确实注册到了 eureka 服务中; 6、在浏览器输入地址 http://localhost:8761/eureka/apps/springms-provider-user 可以看到自定义的四、下载地址信息以及用户微服务的相关信息成功的被展示出来了; ****************************************************************************************/ /**************************************************************************************** 二、用户微服务接口测试(给 springms-discovery-eureka-ha 模块做测试,测试EurekaClient客户端注册进EurekaServer高可用集群中): 1、注解:EnableEurekaClient 2、修改 defaultZone 的接入地址值如下: ################################################################################### # 测试二:测试EurekaClient客户端注册进EurekaServer高可用集群中 defaultZone: http://admin:admin@peer1:8401/eureka,,http://admin:admin@peer2:8402/eureka,,http://admin:admin@peer3:8403/eureka ################################################################################### 3、启动 springms-discovery-eureka-ha 模块服务,启动3个端口; 4、启动 springms-provider-user 模块服务,启动1个端口; 5、在浏览器输入地址http://localhost:7900/simple/1 可以看到信息成功的被打印出来,说明用户微服务正常; 6、在浏览器输入地址 http://localhost:8401 并输入用户名密码 admin/admin 进入Eureka微服务显示在网页中,说明用户微服务确实注册到了 eureka 服务中; 7、在浏览器输入地址 http://localhost:8401/eureka/apps/springms-provider-user 可以看到自定义的 信息以及用户微服务的相关信息成功的被展示出来了; 8、在浏览器输入地址 http://localhost:8402/eureka/apps/springms-provider-user 可以看到自定义的 信息以及用户微服务的相关信息成功的被展示出来了; 9、在浏览器输入地址 http://localhost:8403/eureka/apps/springms-provider-user 可以看到自定义的 信息以及用户微服务的相关信息成功的被展示出来了; ****************************************************************************************/
https://gitee.com/ylimhhmily/SpringCloudTutorial.git
SpringCloudTutorial交流QQ群: 235322432
SpringCloudTutorial交流微信群: 微信沟通群二维码图片链接
欢迎关注,您的肯定是对我最大的支持!!!
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/70445.html
摘要:第篇电影微服务,也注册到中,通过协议访问已注册到生态圈中的用户微服务一大致介绍在服务治理框架中,微服务与微服务之间通过协议进行通信用户微服务作为消费方电影微服务作为提供方都注册到中在电影微服务层通过的硬编码配置方式实现服务之间的通信二实现 SpringCloud(第 005 篇)电影微服务,也注册到 EurekaServer 中,通过 Http 协议访问已注册到生态圈中的用户微服务 -...
摘要:第篇服务发现服务端微服务一大致介绍众所周知,在现在互联网开发中,访问地址的和端口号是动态的,一个服务停掉再重新启用后和端口就可能发生了改变,所以用硬编码是肯定不行了。再对外提供服务的时候便不再使用挂掉的服务提供者的和端口。 SpringCloud(第 003 篇)服务发现服务端EurekaServer微服务 - 一、大致介绍 1、众所周知,在现在互联网开发中,访问地址的IP和端口号是...
SpringCloud(第 051 篇)EurekaServer集群高可用注册中心以及简单的安全认证 - 一、大致介绍 1、前面章节分析了一下 Eureka 的源码,我们是不是在里面注意到了 Peer 节点的复制,为什么要复制节点同步信息呢,其实就是为了同一个集群之间的EurekaServer一致性方案的一个实现; 2、于是我们在本章节就真正的来通过代码来实现一下EurekaServer之间的高...
摘要:第篇电影微服务,使用在客户端进行负载均衡一大致介绍是发布的云中间层服务开源项目,主要功能是提供客户端负载均衡算法。而被注解后,能过用负载均衡,主要是维护了一个被注解的列表,并给列表中的添加拦截器,进而交给负载均衡器去处理。 SpringCloud(第 006 篇)电影微服务,使用 Ribbon 在客户端进行负载均衡 - 一、大致介绍 1、Ribbon 是 Netflix 发布的云中间层...
摘要:英文意思就是说提供一个回退机制当路由后面的服务发生故障时。注意注解能注册到服务上,是因为该注解包含了客户端的注解,该是一个复合注解。地址可以查看该微服务网关代理了多少微服务的。 SpringCloud(第 025 篇)Zuul 路由后面的微服务挂了后,Zuul 提供了一种回退机制来应对熔断处理 - 一、大致介绍 1、在一些不稳定因素导致路由后面的微服务宕机或者无响应时,zuul 就会累...
阅读 2949·2021-09-23 11:32
阅读 2918·2021-09-22 15:12
阅读 1708·2019-08-30 14:07
阅读 3448·2019-08-29 16:59
阅读 1640·2019-08-29 11:11
阅读 2307·2019-08-26 13:50
阅读 2426·2019-08-26 13:49
阅读 2621·2019-08-26 11:49