我們已經編寫一個服務提供者,在我們的高可用Eureka當中注冊,將這個服務注冊成功,我們來看一下,如何在高可用的Eureka,去構建我們的Consumer,那么我們要編寫的Consumer是什么意思呢,先跟大家說一下,我們之前寫的Provider,它是一個服務提供者,也就是未來他要為誰提供服務呢,我們現在要編寫的Consumer,也就是未來在我的Consumer當中,會有調用Provider服務當中接口的一個現象,那我們先把Consumer的代碼構建出來,我們就直接拷貝Provider就可以了,springcloud-eureka-consumer10.40.8.152:9090/user然后我們還是去改他的pom文件,然后pom其他的內容不用動,Consumer也是Eureka的客戶端,spring-cloud-starter-eureka,這里表示的是eureka的artifactId就可以了,創建項目,然后我們項目創建好以后,去調用provider的代碼,我要在這個服務里去調用這個服務里的接口,就是去調用UserController接口,那么我們在哪兒調用,做過分布式開發的,做過SOA的項目,比如電商項目,大家都知道,我在我的項目當中,去調用服務的時候,肯定是在我的項目業務層去調用的,所以我現在的Consumer里,含有業務層的代碼,所以我這里還是要去創建一個業務層,把它放到.service包下,然后我們起個名,比如我們叫userService,然后在userService里干嘛呢,@Service肯定要加一個注解,因為我們要加入到Spring IOC容器當中的,然后這里我們有一個方法,比如他也返回一個List,也叫getUsers吧,然后在getUsers當中呢,我們先返回一個空,先把這個結構搭建出來,這樣我們的Consumer就編寫好了,我們先把啟動類啟動一下,注意在Consumer當中,你的啟動類也要加@EnableEurekaClient,因為Conusmer也是Eureka的一個客戶端,所以無論是Provider還是Consumer,都是客戶端,那么這里我們說一下,現在Consumer要向Provider去消費,那么在這里呢,他也需要在注冊中心當中,去注冊,在我們的Eureka注冊中心當中去注冊,這樣他才能消費注冊中心當中的服務,那么在我們加了@EnableEurekaClient以后呢,其實我們再運行的時候,對于配置文件當中,就會根據你當前注冊中心的地址,注冊到相應的節點當中,這一點和Provider的配置是一樣的,所以這塊需要注意這樣一個點,就是服務的消費者與提供者,都需要在Eureka注冊中心注冊,這樣我們才能做服務與服務之間的通信,所以我們還是在Consumer的配置文件當中,要保留這句話的,Consumer的配置文件,那我們先解決第一個問題,我們現在啟動一下,我們的Consumer服務能不能在我們的注冊中心完成注冊,運行,還有的地方需要改,端口,現在如果我們的provider在啟動的話,端口搶占了,所以我們得改一下,9091,然后我們啟動,啟動Consumer,啟動成功,9091,然后我們刷新http://10.40.8.152:8761/SPRINGCLOUD-EUREKA-CONSUMER n/a (1) (1) UP (1) - springcloud-eureka-consumer:10.40.8.144:9091這里是是不是監聽了9091的服務,我的服務Provider監聽9090也在這里,所以如果我們服務和服務之間要想通信,比如我的Consumer要去消費我的提供者,調他的服務,那么首先大家一定要記住就是,你的服務提供者和服務消費者,比如都要在eureka的注冊中心,完成服務的注冊,否則是無法通信的,然后我們將業務層的代碼粘到筆記當中,@Service public class UserService {public List<User> getUsers(){return null;} }這一塊我們先空著,先不粘,因為我們首先是先把環境搭建好,把Consumer的項目構建好,然后把業務層構建好,那么我們把環境搭建好了,未來我們要關注的就是,在業務層當中,怎么去調用Provider的接口了,我們已經把環境搭建好了 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.learn.cloud</groupId><artifactId>springcloud-eureka-consumer</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.12.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties> <dependencyManagement><dependencies><dependency> <groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Dalston.SR1</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId></dependency></dependencies><!-- 這個插件,可以將應用打包成一個可執行的jar包 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project> server.port=9091 eureka.client.serviceUrl.defaultZone=http://10.40.8.152:8761/eureka spring.application.name=springcloud-eureka-consumer eureka.instance.prefer-ip-address=true eureka.instance.instance-id=${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}} package com.learn.pojo;public class User {private int userid;private String username;private int userage;public int getUserid() {return userid;}public void setUserid(int userid) {this.userid = userid;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public int getUserage() {return userage;}public void setUserage(int userage) {this.userage = userage;}public User(int userid, String username, int userage) {super();this.userid = userid;this.username = username;this.userage = userage;}public User() {super();// TODO Auto-generated constructor stub}} package com.learn.service;import java.util.List;import org.springframework.stereotype.Service;import com.learn.pojo.User;@Service public class UserService {public List<User> getUsers(){return null;} } package com.learn;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@EnableEurekaClient @SpringBootApplication public class EurekaConsumerApplication {public static void main(String[] args) {SpringApplication.run(EurekaConsumerApplication.class, args);} }

?

總結

以上是生活随笔為你收集整理的创建consumer服务的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。