本次分享的是關於springcloud服務註冊與發現的內容,將經過分別搭建服務中心,服務註冊,服務發現來講明;如今北京這邊不少創業公司都開始往springcloud靠了,多是因爲文檔和組件比較豐富的緣由吧,畢竟是一款目前來講比較完善的微服務架構;本次分享但願能給你們帶來好的幫助;spring
就我如今瞭解到而且用的比較多的註冊中心有zookeeper和Eureka,個人上上篇文章分享了dubbo+zookeeper來構建服務,所以本次用的是Eureka,springcloud框架也是推薦它來做爲註冊中心,固然能夠集成其餘的服註冊中心,畢竟springcloud依賴於springboot來構建項目的,所以集成其餘組件是很快的;首先建立註冊中心項目eureka_server,經過以下引入依賴:api
1 <dependency> 2 <groupId>org.springframework.cloud</groupId> 3 <artifactId>spring-cloud-starter-eureka-server</artifactId> 4 </dependency>
而後在application.yml文件中增長配置項:springboot
1 server: 2 port: 2001 3 spring: 4 application: 5 name: eureka-server 6 eureka: 7 client: 8 register-with-eureka: false #禁止本身當作服務註冊 9 fetch-registry: false #屏蔽註冊信息 10 instance: 11 prefer-ip-address: true 12 instance-id: ${spring.application.name}:${server.port}
配置完成後,還須要再啓動類增長註解 @EnableEurekaServer ,設置基本完成便可運行,訪問 http://localhost:2001/ 獲得以下界面:服務器
有了服務註冊中心,咱們還須要提供一些服務而且把這些服務註冊到服務中心去,這裏爲了方便先建立一個服務提供者和消費者共同使用的接口模塊項目eureka_api,並建立以下接口和請求返回參數實體類:架構
1 public interface UserInterface { 2 3 @PostMapping("/users") 4 MoRp<List<MoUser>> getUsers(MoRq rq); 5 6 @GetMapping("/msg") 7 String getMsg(); 8 }
MoUser實體:app
1 public class MoUser { 2 3 private long id; 4 private String userName; 5 private String userPwd; 6 7 public long getId() { 8 return id; 9 } 10 11 public void setId(long id) { 12 this.id = id; 13 } 14 15 public String getUserName() { 16 return userName; 17 } 18 19 public void setUserName(String userName) { 20 this.userName = userName; 21 } 22 23 public String getUserPwd() { 24 return userPwd; 25 } 26 27 public void setUserPwd(String userPwd) { 28 this.userPwd = userPwd; 29 } 30 }
而後建立咱們的服務提供端的模塊eureka_provider,一樣引入eureka依賴不過和server端有點區別:框架
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency>
再來建立服務提供端要提供的服務UserController,而且實現咱們eureka_api模塊中的UserInterface接口,代碼以下:ide
1 @RestController 2 public class UserController implements UserInterface { 3 4 @Autowired 5 private HttpServletRequest request; 6 7 @Override 8 public MoRp<List<MoUser>> getUsers(MoRq rq) { 9 10 MoRp<List<MoUser>> rp = new MoRp<>(); 11 12 List<MoUser> list = new ArrayList<>(); 13 for (int i = 0; i < 5; i++) { 14 MoUser moUser = new MoUser(); 15 moUser.setId(i); 16 moUser.setUserName("神牛" + i); 17 list.add(moUser); 18 } 19 rp.setT(list); 20 rp.setStatus(list.size() >= 1 ? 1 : 0); 21 rp.setMessage(list.size() >= 1 ? "" : "暫無數據"); 22 return rp; 23 } 24 25 @Override 26 public String getMsg() { 27 28 return "這裏是provider,端口:"+ request.getServerPort(); 29 } 30 }
這裏須要注意的是Controller的兩個服務接口中沒有再加PostMapping或GetMapping,由於這個由被實現接口申明瞭;定義好了users和msg服務後,咱們還須要能把他們注入到服務註冊中心去,所以須要以下application.yml的配置:微服務
1 spring: 2 application: 3 name: eureka-provider #服務名稱 4 eureka: 5 client: 6 service-url: 7 defaultZone: http://localhost:2001/eureka/ #服務中心地址 8 instance: 9 prefer-ip-address: true 10 instance-id: ${spring.application.name}:${server.port} 11 server: 12 port: 2004
咱們還須要在啓動類增長以下標記 @EnableEurekaClient ,它表示啓動eureka客戶端,由於服務提供者相對服務中心來講是屬於客戶端的存在;當運行eureka_provider項目的時候,咱們在註冊中心能看到以下信息:測試
爲了保證服務提供端接口沒問題,咱們能夠直接點擊eureka-provider:2004,而後增長要方法接口的路徑我這裏是:http://192.168.153.148:2004/msg,便可獲得以下正常訪問接口返回的信息:
有了接口服務,咱們還須要消費服務,所以建立module項目eureka_consumer,由於這裏採用fegin僞客戶端的方式來訪問咱們服務提供端,而且一樣須要引入eureka的依賴:
1 <dependency> 2 <groupId>org.springframework.cloud</groupId> 3 <artifactId>spring-cloud-starter-eureka</artifactId> 4 </dependency> 5 <dependency> 6 <groupId>org.springframework.cloud</groupId> 7 <artifactId>spring-cloud-starter-feign</artifactId> 8 </dependency>
而後在service層定義UserService服務而且實現公共接口模塊eureka_api中的接口,代碼如:
1 @FeignClient(value = "eureka-provider") 2 public interface UserService extends UserInterface { 3 4 }
經過FeignClient來指定調用的服務端應用名稱eureka-provider,這名稱對應註冊在服務中心的Application目錄下 ,在Controller層建立一個響應的輸出UserController並分別提供兩個展現的接口,代碼如:
1 @RestController 2 public class UserController{ 3 4 @Autowired 5 private UserService userService; 6 7 @GetMapping("/users") 8 public MoRp<List<MoUser>> getUsers(MoRq rq) { 9 return userService.getUsers(rq); 10 } 11 12 @GetMapping("/msg") 13 public String getMsg() { 14 return userService.getMsg(); 15 } 16 }
一樣Consumer端也須要在application.yml中配置一些信息:
1 spring: 2 application: 3 name: eureka-consumer 4 eureka: 5 client: 6 service-url: 7 defaultZone: http://localhost:2001/eureka/ #註冊中心地址 8 instance: 9 prefer-ip-address: true 10 instance-id: ${spring.application.name}:${server.port} 11 server: 12 port: 2005
配置基本和provider端差很少,最後須要在啓動類申明以下註解:
1 @SpringBootApplication 2 @EnableDiscoveryClient //消費者客戶端 3 @EnableFeignClients //feign客戶端 4 public class EurekaConsumerApplication { 5 public static void main(String[] args) { 6 SpringApplication.run(EurekaConsumerApplication.class, args); 7 } 8 }
啓動eureka_consumer項目後,咱們能在註冊中心看到它註冊進來的信息:
而後經過訪問eureka_consumer消費方的接口測試eureka_provider服務提供方的接口數據知否能正常響應,接口地址 http://192.168.153.148:2005/msg :
經過訪問consumer獲得了provider的結果,這就是服務註冊和發現的基本測試流程;至於消費方怎麼請求到提供方接口的,咱們經過以下手工圖可解:
由上面手工圖來看,服務中心承擔着很重要的角色,一般這種服務中心不只僅只搭建一個,所以須要搭建一套高可用的服務中心出來;其實很簡單provider和consumer配置都不用動,咱們只須要在第一節點的eureka-server項目的application.yml中配置下而且在多啓動幾個不一樣端口的服務就好了(同一臺服務器是多個端口,不一樣服務器端口多是同樣的):
1 server: 2 port: 2001 3 spring: 4 application: 5 name: eureka-server 6 eureka: 7 client: 8 register-with-eureka: true #配置高可用的時候須要開放本身註冊本身 9 fetch-registry: true 10 service-url: 11 defaultZone: http://localhost:2002/eureka/ #註冊到端口2002的eureka中 12 # defaultZone: http://localhost:2001/eureka/ 13 instance: 14 prefer-ip-address: true 15 instance-id: ${spring.application.name}:${server.port} 16 server: 17 eviction-interval-timer-in-ms: 2000 #剔除失效服務間隔
高可用配置須要注意如下幾點:
這裏我建立了兩個註冊中心地址分別爲:http://localhost:2001/,http://localhost:2002/;因爲以前provider和consumer配置的註冊中心地址都是2001端口的,爲了驗證高可用咱們須要訪問2002端口註冊中心,效果如:
可以看到2002端口有着2001端口一樣的註冊信息,當我關閉2001端口的應用時,2002仍是可以查到provider和consumer的信息,更詳細的配置能夠參照官網說明。