前幾篇主要集中在注冊(cè)中心eureka的使用上，接下來可以創(chuàng)建服務(wù)提供者provider來注冊(cè)到eureka。
湛江網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)建站！從網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站設(shè)計(jì)等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營維護(hù)。創(chuàng)新互聯(lián)建站2013年開創(chuàng)至今到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)建站。
demo源碼見： https://github.com/Ryan-Miao/spring-cloud-Edgware-demo/tree/master/provider-demo
為了方便版本控制，接下來的項(xiàng)目都是基于https://github.com/Ryan-Miao/spring-cloud-Edgware-demo 這個(gè)parent配置的。
創(chuàng)建子moudle provider-demo
創(chuàng)建一個(gè)子module，項(xiàng)目名叫provider-demo. 填充springboot和springcloud依賴
org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-actuator org.springframework.boot spring-boot-devtools true com.fasterxml.jackson.datatype jackson-datatype-jsr310 org.springframework.cloud spring-cloud-starter-eureka io.springfox springfox-swagger2 io.springfox springfox-swagger-ui com.google.guava guava org.projectlombok lombok true net.logstash.logback logstash-logback-encoder
spring-boot-starter-web 提供web能力，必須spring-boot-starter-actuator 提供項(xiàng)目統(tǒng)計(jì)和基礎(chǔ)的監(jiān)控endpoint, 想要使用spring-boot-admin監(jiān)控就必須添加了 spring-boot-devtools 開發(fā)模式 jackson-datatype-jsr310 可以解決Java8新的時(shí)間APILocalDate解體 spring-cloud-starter-eureka eureka客戶端，負(fù)責(zé)維護(hù)心跳和注冊(cè) swagger 提供Restful契約 lombok 看起來很清爽的編譯級(jí)別getter setter工具 guava 大而全的Java必備類庫 logstash-logback-encoder 想要收集日志到ELK，使用這個(gè)appender
啟動(dòng)類
重慶分公司
重慶分公司
@EnableDiscoveryClient
@SpringBootApplication
public class ProviderDemoApplication {
public static void main(String[] args) {
SpringApplication.run(ProviderDemoApplication.class, args);
}
}@EnableDiscoveryClient 來啟用服務(wù)注冊(cè)
這個(gè)ProviderDemoApplication應(yīng)該放置于項(xiàng)目包的最外層，因?yàn)锧SpringbootAppliatin包含了@ComponentScan的注解，默認(rèn)掃描本類包下，否則必須手動(dòng)指定scan。
Swagger
swagger就是一個(gè)配置類
@EnableSwagger2
@Configuration
public class SwaggerConfiguration {
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
.title("服務(wù)提供者 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());
}
}對(duì)于swagger頁面的路由，需要我們來引導(dǎo)下：
創(chuàng)建一個(gè)controller來導(dǎo)航
@Controller
public class HomeController {
@GetMapping(value = {"/api", "/"})
public String api() {
return "redirect:/swagger-ui.html";
}
}來一個(gè)Controller 接口
@Api
@RestController
@RequestMapping("/api/v1/users")
public class UserController{
private List users = Lists.newArrayList(
new User(1, "譚浩強(qiáng)", 100, LocalDate.now()),
new User(2, "嚴(yán)蔚敏", 120, LocalDate.now()),
new User(3, "譚浩強(qiáng)", 100, LocalDate.now()),
new User(4, "James Gosling", 150, LocalDate.now()),
new User(6, "Doug Lea", 150, LocalDate.now())
);
@GetMapping("/")
public List list() {
return users.stream()
.map(u -> new UserVo(u.getId(), u.getName(), u.getAge(), u.getBirth()))
.collect(Collectors.toList());
}
} 一些簡(jiǎn)單的環(huán)境配置
application.yml
spring:
application:
name: provider-demo
jackson:
serialization:
WRITE_DATES_AS_TIMESTAMPS: false
default-property-inclusion: non_null
#服務(wù)過期時(shí)間配置,超過這個(gè)時(shí)間沒有接收到心跳EurekaServer就會(huì)將這個(gè)實(shí)例剔除
#注意，EurekaServer一定要設(shè)置eureka.server.eviction-interval-timer-in-ms否則這個(gè)配置無效，這個(gè)配置一般為服務(wù)刷新時(shí)間配置的三倍
#默認(rèn)90s
eureka.instance.lease-expiration-duration-in-seconds: 15
#服務(wù)刷新時(shí)間配置，每隔這個(gè)時(shí)間會(huì)主動(dòng)心跳一次
#默認(rèn)30s
eureka.instance.lease-renewal-interval-in-seconds: 5
server:
port: 8082
springfox:
documentation:
swagger:
v2:
path: /swagger-resources/api-docs
log:
path: logsapplication-dev.yml
management: security: enabled: false eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ logstash: url: localhost:4560
這里需要提一點(diǎn)，由于我集成了logstash, 所以必須安裝好logstash, 見ELK入門使用。 當(dāng)然可以跳過，只要不提供logback.xml的配置就行，把依賴中l(wèi)ogstash移除即可。
Log配置
默認(rèn)采用logback作為日志框架，簡(jiǎn)單配置如下，對(duì)于不想使用logstash的，移除logstash的appender即可。
在resource下新建logback-spring.xml
<?xml version="1.0" encoding="UTF-8"?>LoggingInterceptor %d{HH:mm:ss.SSS} %X{req.remoteHost} %X{req.requestURI} ${appName} [%thread] %-5level %logger{36} - %msg%n ${log.path}/${appName}.%d{yyyy-MM-dd}.log %d{HH:mm:ss.SSS} ${appName} %X{req.remoteHost} %X{req.requestURI} %X{req.userAgent} %X{req.method} - [%thread] %-5level %logger{36} - %msg%n ${logstashurl}
啟動(dòng)
確保eureka已啟動(dòng)，admin最好也啟動(dòng)，方便查看app狀態(tài)，ELK的日志系統(tǒng)也最好可以使用。當(dāng)然，只有eureka是剛需。
編譯打包
mvn clean install package spring-boot:repackage
運(yùn)行main方法，指定profile為dev, 可以在idea中編輯運(yùn)行配置，添加參數(shù)
--spring.profiles.active=dev
或者命令行jar啟動(dòng)
啟動(dòng)后，訪問eureka
訪問admin
訪問provider-demo
暴露我們的API給consumer
既然有服務(wù)提供者，必然是為了consumer消費(fèi)。consumer應(yīng)該如何消費(fèi)？手動(dòng)調(diào)用這個(gè)http請(qǐng)求即可。前面提到swagger Restful契約，就是服務(wù)提供者提供請(qǐng)求訪問的參數(shù)和要求。consumer如果手動(dòng)去開發(fā)這個(gè)client必然耗時(shí)，而且容易出錯(cuò)。所以，作為服務(wù)提供者，理應(yīng)提供sdk或者client給consumer來用。
在spring cloud技術(shù)體系中，遠(yuǎn)程調(diào)用自然是重中之重。目前我找到的具體用法為Feign+Ribbon+Hystrix.
通過Feign的聲明式接口對(duì)接，實(shí)現(xiàn)了consumer對(duì)provider的調(diào)用。ribbon客戶端負(fù)載均衡，hystrix作健康熔斷。
在這里，我們就首先要提供Feign的接口了。
把controller的api提煉成一個(gè)接口。首先，我們創(chuàng)建一個(gè)新的項(xiàng)目
https://github.com/Ryan-Miao/spring-cloud-Edgware-demo/tree/master/provider-api
將這個(gè)項(xiàng)目放到provider-demo的依賴列表里
com.test provider-api 0.0.1-SNAPSHOT
抽離UserApi接口道provider-api項(xiàng)目中
@RequestMapping("/api/v1/users")
public interface UserApi {
@GetMapping("/")
List list();
} 在provider-demo的controller里改造如下
@Api
@RestController
public class UserController implements UserApi {
private List users = Lists.newArrayList(
new User(1, "譚浩強(qiáng)", 100, LocalDate.now()),
new User(2, "嚴(yán)蔚敏", 120, LocalDate.now()),
new User(3, "譚浩強(qiáng)", 100, LocalDate.now()),
new User(4, "James Gosling", 150, LocalDate.now()),
new User(6, "Doug Lea", 150, LocalDate.now())
);
@Override
public List list() {
return users.stream()
.map(u -> new UserVo(u.getId(), u.getName(), u.getAge(), u.getBirth()))
.collect(Collectors.toList());
}
} 這樣，controller沒有變化，只是被抽離了api路徑。而獨(dú)立出來的module provider-api就是我們給consumer提供的client。下一節(jié)使用consumer消費(fèi)。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。
