SpringCloud如何創(chuàng)建一個服務提供者provider
前幾篇主要集中在注冊中心eureka的使用上，接下來可以創(chuàng)建服務提供者provider來注冊到eureka。
demo源碼見： https://github.com/Ryan-Miao/spring-cloud-Edgware-demo/tree/master/provider-demo
為了方便版本控制，接下來的項目都是基于https://github.com/Ryan-Miao/spring-cloud-Edgware-demo 這個parent配置的。
創(chuàng)建子moudle provider-demo
創(chuàng)建一個子module，項目名叫provider-demo. 填充springboot和springcloud依賴
<dependencies> <!--springboot 依賴start--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>com.fasterxml.jackson.datatype</groupId> <artifactId>jackson-datatype-jsr310</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <!--springboot 依賴結束--> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger2</artifactId> </dependency> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger-ui</artifactId> </dependency> <!--工具類 start--> <dependency> <groupId>com.google.guava</groupId> <artifactId>guava</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>net.logstash.logback</groupId> <artifactId>logstash-logback-encoder</artifactId> </dependency> <!--工具類end--> </dependencies>
spring-boot-starter-web 提供web能力，必須spring-boot-starter-actuator 提供項目統(tǒng)計和基礎的監(jiān)控endpoint, 想要使用spring-boot-admin監(jiān)控就必須添加了 spring-boot-devtools 開發(fā)模式 jackson-datatype-jsr310 可以解決Java8新的時間APILocalDate解體 spring-cloud-starter-eureka eureka客戶端，負責維護心跳和注冊 swagger 提供Restful契約 lombok 看起來很清爽的編譯級別getter setter工具 guava 大而全的Java必備類庫 logstash-logback-encoder 想要收集日志到ELK，使用這個appender
啟動類
@EnableDiscoveryClient
@SpringBootApplication
public class ProviderDemoApplication {
public static void main(String[] args) {
SpringApplication.run(ProviderDemoApplication.class, args);
}
}
@EnableDiscoveryClient 來啟用服務注冊
這個ProviderDemoApplication應該放置于項目包的最外層，因為@SpringbootAppliatin包含了@ComponentScan的注解，默認掃描本類包下，否則必須手動指定scan。
Swagger
swagger就是一個配置類
@EnableSwagger2
@Configuration
public class SwaggerConfiguration {
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
.title("服務提供者 API")
.description("提供用戶信息查詢")
.termsOfServiceUrl("")
.version("1.0.0")
.build();
}
/**
* 定義api配置.
*/
@Bean
public Docket api() {
return new Docket(DocumentationType.SWAGGER_2)
.select()
.apis(RequestHandlerSelectors.withClassAnnotation(Api.class))
.build()
.apiInfo(apiInfo());
}
}
對于swagger頁面的路由，需要我們來引導下：
創(chuàng)建一個controller來導航
@Controller
public class HomeController {
@GetMapping(value = {"/api", "/"})
public String api() {
return "redirect:/swagger-ui.html";
}
}
來一個Controller 接口
@Api
@RestController
@RequestMapping("/api/v1/users")
public class UserController{
private List<User> users = Lists.newArrayList(
new User(1, "譚浩強", 100, LocalDate.now()),
new User(2, "嚴蔚敏", 120, LocalDate.now()),
new User(3, "譚浩強", 100, LocalDate.now()),
new User(4, "James Gosling", 150, LocalDate.now()),
new User(6, "Doug Lea", 150, LocalDate.now())
);
@GetMapping("/")
public List<UserVo> list() {
return users.stream()
.map(u -> new UserVo(u.getId(), u.getName(), u.getAge(), u.getBirth()))
.collect(Collectors.toList());
}
}
一些簡單的環(huán)境配置
application.yml
spring:
application:
name: provider-demo
jackson:
serialization:
WRITE_DATES_AS_TIMESTAMPS: false
default-property-inclusion: non_null
#服務過期時間配置,超過這個時間沒有接收到心跳EurekaServer就會將這個實例剔除
#注意，EurekaServer一定要設置eureka.server.eviction-interval-timer-in-ms否則這個配置無效，這個配置一般為服務刷新時間配置的三倍
#默認90s
eureka.instance.lease-expiration-duration-in-seconds: 15
#服務刷新時間配置，每隔這個時間會主動心跳一次
#默認30s
eureka.instance.lease-renewal-interval-in-seconds: 5
server:
port: 8082
springfox:
documentation:
swagger:
v2:
path: /swagger-resources/api-docs
log:
path: logs
application-dev.yml
management: security: enabled: false eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ logstash: url: localhost:4560
這里需要提一點，由于我集成了logstash, 所以必須安裝好logstash, 見ELK入門使用。 當然可以跳過，只要不提供logback.xml的配置就行，把依賴中l(wèi)ogstash移除即可。
Log配置
默認采用logback作為日志框架，簡單配置如下，對于不想使用logstash的，移除logstash的appender即可。
在resource下新建logback-spring.xml
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<springProperty scope="context" name="appName" source="spring.application.name"
defaultValue="unknown"/>
<springProperty scope="context" name="log.path" source="log.path"
defaultValue="logs"/>
<springProperty scope="context" name="logstashurl" source="logstash.url"
defaultValue="localhost:4560"/>
<include resource="org/springframework/boot/logging/logback/base.xml"/>
<!--輸出到控制臺-->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">LoggingInterceptor
<encoder>
<pattern>%d{HH:mm:ss.SSS} %X{req.remoteHost} %X{req.requestURI}
${appName} [%thread] %-5level %logger{36} - %msg%n
</pattern>
</encoder>
</appender>
<!--輸出到文件-->
<appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${log.path}/${appName}.%d{yyyy-MM-dd}.log</fileNamePattern>
</rollingPolicy>
<encoder>
<pattern>%d{HH:mm:ss.SSS} ${appName} %X{req.remoteHost} %X{req.requestURI}
%X{req.userAgent}
%X{req.method} - [%thread] %-5level %logger{36} - %msg%n
</pattern>
</encoder>
</appender>
<!-- 輸出到logstash-->
<appender name="LOGSTASH" class="net.logstash.logback.appender.LogstashTcpSocketAppender">
<destination>${logstashurl}</destination>
<encoder charset="UTF-8" class="net.logstash.logback.encoder.LogstashEncoder"/>
</appender>
<springProfile name="dev">
<root level="info">
<appender-ref ref="console"/>
<appender-ref ref="file"/>
<appender-ref ref="LOGSTASH"/>
</root>
</springProfile>
<springProfile name="test, prod">
<root level="info">
<appender-ref ref="file"/>
<appender-ref ref="LOGSTASH"/>
</root>
</springProfile>
</configuration>
啟動
確保eureka已啟動，admin最好也啟動，方便查看app狀態(tài)，ELK的日志系統(tǒng)也最好可以使用。當然，只有eureka是剛需。
編譯打包
mvn clean install package spring-boot:repackage
運行main方法，指定profile為dev, 可以在idea中編輯運行配置，添加參數(shù)
--spring.profiles.active=dev
或者命令行jar啟動
啟動后，訪問eureka
訪問admin
訪問provider-demo
暴露我們的API給consumer
既然有服務提供者，必然是為了consumer消費。consumer應該如何消費？手動調(diào)用這個http請求即可。前面提到swagger Restful契約，就是服務提供者提供請求訪問的參數(shù)和要求。consumer如果手動去開發(fā)這個client必然耗時，而且容易出錯。所以，作為服務提供者，理應提供sdk或者client給consumer來用。
在spring cloud技術體系中，遠程調(diào)用自然是重中之重。目前我找到的具體用法為Feign+Ribbon+Hystrix.
通過Feign的聲明式接口對接，實現(xiàn)了consumer對provider的調(diào)用。ribbon客戶端負載均衡，hystrix作健康熔斷。
在這里，我們就首先要提供Feign的接口了。
把controller的api提煉成一個接口。首先，我們創(chuàng)建一個新的項目
https://github.com/Ryan-Miao/spring-cloud-Edgware-demo/tree/master/provider-api
將這個項目放到provider-demo的依賴列表里
<!--內(nèi)部依賴--> <dependency> <groupId>com.test</groupId> <artifactId>provider-api</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> <!--內(nèi)部依賴end-->
抽離UserApi接口道provider-api項目中
@RequestMapping("/api/v1/users")
public interface UserApi {
@GetMapping("/")
List<UserVo> list();
}
在provider-demo的controller里改造如下
@Api
@RestController
public class UserController implements UserApi {
private List<User> users = Lists.newArrayList(
new User(1, "譚浩強", 100, LocalDate.now()),
new User(2, "嚴蔚敏", 120, LocalDate.now()),
new User(3, "譚浩強", 100, LocalDate.now()),
new User(4, "James Gosling", 150, LocalDate.now()),
new User(6, "Doug Lea", 150, LocalDate.now())
);
@Override
public List<UserVo> list() {
return users.stream()
.map(u -> new UserVo(u.getId(), u.getName(), u.getAge(), u.getBirth()))
.collect(Collectors.toList());
}
}
這樣，controller沒有變化，只是被抽離了api路徑。而獨立出來的module provider-api就是我們給consumer提供的client。下一節(jié)使用consumer消費。
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
這篇文章主要介紹了Java中Date日期類的使用方法,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-08-08
Java使用list集合remove需要注意的事項(使用示例)
List集合的一個特點是它其中的元素是有序的，也就是說元素的下標是根據(jù)插入的順序來的，在刪除頭部或者中間的一個元素后，后面的元素下標會往前移動，本文給大家介紹Java使用list集合remove需要注意的事項，感興趣的朋友一起看看吧2022-01-01
利用Springboot+Caffeine實現(xiàn)本地緩存實例代碼
Caffeine是一個基于Java8開發(fā)的提供了近乎最佳命中率的高性能的緩存庫,下面這篇文章主要給大家介紹了關于利用Springboot+Caffeine實現(xiàn)本地緩存的相關資料,需要的朋友可以參考下2023-01-01
在Java編程里，使用private關鍵字修飾了一個成員，只有成員內(nèi)部可以訪問，其余成員都不可訪問，今天說明一下private功能失效的問題。2020-10-10
這篇文章主要介紹了Python爬蟲 12306搶票開源代碼過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-09-09
Python爬蟲之爬取2020女團選秀數(shù)據(jù)
本文將對比《青春有你2》和《創(chuàng)造營2020》全體小姐姐，鑒于兩個節(jié)目的數(shù)據(jù)采集和處理過程基本相似，在使用Python做數(shù)據(jù)爬蟲采集的章節(jié)中將只以《創(chuàng)造營2020》為例做詳細介紹。感興趣的同學可以照貓畫虎去實操一下《青春有你2》的數(shù)據(jù)爬蟲采集，需要的朋友可以參考下2021-04-04
@Scheduled 由Spring定義,用于將方法設置為調(diào)度任務,下面這篇文章主要給大家介紹了關于Spring中@Scheduled功能的使用方法,文中通過示例代碼介紹的非常詳細,需要的朋友可以參考下2022-04-04
SpringCloud實現(xiàn)基于RabbitMQ消息隊列的詳細步驟
在Spring Cloud框架中,我們可以利用RabbitMQ實現(xiàn)強大而可靠的消息隊列系統(tǒng),本篇將詳細介紹如何在Spring Cloud項目中集成RabbitMQ,并創(chuàng)建一個簡單的消息隊列,感興趣的朋友一起看看吧2024-03-03
java后端pageHelper分頁實現(xiàn)方法步驟
這篇文章主要給大家介紹了關于java后端pageHelper分頁實現(xiàn)方法的相關資料,在我們的Java項目中分頁是必不可少的數(shù)據(jù)展示頁面,文中通過圖文以及示例代碼介紹的非常詳細,需要的朋友可以參考下2023-07-07
這篇文章主要介紹了解決spring boot環(huán)境切換失效的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09