<dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-security</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-security</artifactId> </dependency> <dependency> <groupId>javax.xml.bind</groupId> <artifactId>jaxb-api</artifactId> </dependency> <dependency> <groupId>com.sun.xml.bind</groupId> <artifactId>jaxb-impl</artifactId> <version>2.3.0</version> </dependency> <dependency> <groupId>org.glassfish.jaxb</groupId> <artifactId>jaxb-runtime</artifactId> <version>2.3.0</version> </dependency> <dependency> <groupId>javax.activation</groupId> <artifactId>activation</artifactId> <version>1.1.1</version> </dependency> </dependencies>
# 应用启动端口 server.port=8090 # 注册中心管理中的 应用名称 spring.application.name=eureka-server # 登陆注册管理中的的账号密码 spring.security.user.roles=SUPERUSER spring.security.user.name=eureka spring.security.user.password=123456 # 是否把自己注册到注册中心 eureka.client.register-with-eureka=true # 是否从eureka上来获取服务的注册信息 eureka.client.fetch-registry=false eureka.instance.hostname=localhost eureka.client.serviceUrl.defaultZone=http://eureka:123456@localhost:8090/eureka
启动注册中心 启动后访问(http://127.0.0.1:8090)
2. 输入设置的账号密码(user:eureka pwd:123456) 3. 进入注册中心页面
@EnableEurekaServer @SpringBootApplication public class EurekaServiceApplication { public static void main(String[] args) { SpringApplication.run(EurekaServiceApplication.class, args); } /** * 忽略 uri /eureka/** 的CSRF检测 */ @EnableWebSecurity static class WebSecurityConfig extends WebSecurityConfigurerAdapter { @Override protected void configure(HttpSecurity http) throws Exception { http.csrf().ignoringAntMatchers("/eureka/**"); super.configure(http); } } }
服务端口 server.port=8081 # 服务应用名称 spring.application.name=provider-ticket # 是否允许使用ip连接 eureka.instance.ip-address=true # 注意 http://用户名:密码@主机:端口/eureka 需要与服务中心里配置的一样 eureka.client.serviceUrl.defaultZone=http://eureka:123456@localhost:8090/eureka
package com.yourdream.providerticket.controller; import com.yourdream.providerticket.service.TicketService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class TicketController { @Autowired TicketService ticketService; @GetMapping("/ticket") public String getTicket(){ System.out.println("server-8081"); return ticketService.getTicket(); } }
package com.yourdream.providerticket.service; import org.springframework.stereotype.Service; @Service public class TicketService { public String getTicket() { return "《哪吒之魔童降世》"; } }
package com.yourdream.providerticket; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class ProviderTicketApplication { public static void main(String[] args) { SpringApplication.run(ProviderTicketApplication.class, args); } }
server.port=8100 spring.application.name=consumer-user eureka.client.serviceUrl.defaultZone=http://eureka:123456@localhost:8090/eureka eureka.instance.ip-address=true
package com.yourdream.consumeruser; 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.context.annotation.Bean; import org.springframework.web.client.RestTemplate; @EnableDiscoveryClient //开启发现服务功能 @SpringBootApplication public class ConsumerUserApplication { public static void main(String[] args) { SpringApplication.run(ConsumerUserApplication.class, args); } @LoadBalanced //开启负载均衡器 @Bean //注册 RestTemplate 服务 public RestTemplate restTemplate() { return new RestTemplate(); } }
package com.yourdream.consumeruser.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; @RestController public class UserController { // 帮助我们向 注册的实例服务 发起http请求 @Autowired RestTemplate restTemplate; @GetMapping("/buy") public String buyTicket(String name) { //PROVIDER-TICKET 服务提供者名称 String forObject = restTemplate.getForObject("http://PROVIDER-TICKET/ticket", String.class); return name + "购买了" + forObject; } }