摘要：環(huán)境搭建注冊中心依賴如下所示配置應(yīng)用啟動端口注冊中心管理中的應(yīng)用名稱登陸注冊管理中的的賬號密碼是否把自己注冊到注冊中心是否從上來獲取服務(wù)的注冊信息啟動注冊中心啟動后訪問登陸界面輸入設(shè)置的賬號密碼進(jìn)

環(huán)境

Java version 1.8

SpringBoot version 2.1.7

搭建注冊中心 Eureka-server

pom.xml 依賴如下所示：

    
        org.springframework.cloud
        spring-cloud-starter-netflix-eureka-server
    

    
        org.springframework.boot
        spring-boot-starter-test
        test
    
    
        org.springframework.boot
        spring-boot-starter-security
    
    
        org.springframework.boot
        spring-boot-starter-security
    

    
        javax.xml.bind
        jaxb-api
    
    
        com.sun.xml.bind
        jaxb-impl
        2.3.0
    
    
        org.glassfish.jaxb
        jaxb-runtime
        2.3.0
    
    
        javax.activation
        activation
        1.1.1
    

配置 Eureka application.properties

# 應(yīng)用啟動端口
server.port=8090

# 注冊中心管理中的 應(yīng)用名稱
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上來獲取服務(wù)的注冊信息
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. 輸入設(shè)置的賬號密碼（user：eureka pwd：123456）

3. 進(jìn)入注冊中心頁面

需要注意的是 需要處理下CSRF不然服務(wù)提供者注冊不進(jìn)來 啟動入口文件如下

EurekaServiceApplication.java

@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);
        }
    }
}

簡單的注冊中心已經(jīng)搭建完成

搭建服務(wù)提供者 Provider-service

首先還是配置文件 application.properties

服務(wù)端口
server.port=8081

# 服務(wù)應(yīng)用名稱
spring.application.name=provider-ticket

# 是否允許使用ip連接
eureka.instance.ip-address=true

# 注意 http://用戶名:密碼@主機(jī):端口/eureka 需要與服務(wù)中心里配置的一樣
eureka.client.serviceUrl.defaultZone=http://eureka:123456@localhost:8090/eureka

啟動 項目后會自動把服務(wù)注冊到配置的服務(wù)中心

以下是我做的測試代碼

TicketController.java

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();
    }
}

TicketService

package com.yourdream.providerticket.service;

import org.springframework.stereotype.Service;

@Service
public class TicketService {

    public String getTicket()
    {
        return "《哪吒之魔童降世》";
    }
}

ProviderTicketApplication

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);
    }

}

到此一個簡單的服務(wù)提供者搭建完成

搭建服務(wù)消費者 Consumer-user

首先還是配置文件 application.properties

server.port=8100
spring.application.name=consumer-user
eureka.client.serviceUrl.defaultZone=http://eureka:123456@localhost:8090/eureka
eureka.instance.ip-address=true

首先需要明確 消費者與服務(wù)提供者之間通訊協(xié)議是HTTP

看下實例代碼

啟動入口 ConsumerUserApplication.java

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 //開啟發(fā)現(xiàn)服務(wù)功能
@SpringBootApplication
public class ConsumerUserApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerUserApplication.class, args);
    }

    @LoadBalanced //開啟負(fù)載均衡器
    @Bean //注冊 RestTemplate 服務(wù)
    public RestTemplate restTemplate()
    {
        return new RestTemplate();
    }
}

UserController.java

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 {

    // 幫助我們向 注冊的實例服務(wù) 發(fā)起http請求
    @Autowired
    RestTemplate restTemplate;

    @GetMapping("/buy")
    public String buyTicket(String name)
    {
        //PROVIDER-TICKET 服務(wù)提供者名稱
        String forObject = restTemplate.getForObject("http://PROVIDER-TICKET/ticket", String.class);
        return name + "購買了" + forObject;
    }
}

啟動服務(wù) 訪問http://127.0.0.1:8100/buy

到此一個簡單的服務(wù)消費者搭建完成

原文