Java 学习路线之环境搭建微服务项目实战及 DevOps 流程实操内容

curl -s "https://get.sdkman.io" | bash  # 安装SDKMAN
source "$HOME/.sdkman/bin/sdkman-init.sh"  # 初始化
sdk install java 21.0.1-tem  # 安装Java 21 LTS

plugins {
    id("org.springframework.boot") version "3.3.0"
    id("io.spring.dependency-management") version "1.1.4"
    kotlin("jvm") version "1.9.20"
}

group = "com.example"
version = "0.0.1-SNAPSHOT"

repositories {
    mavenCentral()
    maven { url = uri("https://repo.spring.io/milestone") }
}

dependencies {
    implementation("org.springframework.boot:spring-boot-starter-webflux")
    implementation("org.springframework.boot:spring-boot-starter-data-r2dbc")
    implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
    runtimeOnly("com.mysql:mysql-connector-j")
    runtimeOnly("dev.miku:r2dbc-mysql")
}

bookstore-microservices/
├── api-gateway/           # API网关服务
├── auth-service/          # 认证授权服务（JWT + Oauth2.1）
├── book-service/          # 图书管理服务（响应式）
├── order-service/         # 订单服务（Kotlin协程）
├── recommendation-service/# 推荐服务（集成AI模型）
└── notification-service/  # 通知服务（WebSocket + SSE）

// BookRepository.kt（R2DBC响应式仓库）
interface BookRepository : ReactiveCrudRepository<Book, String> {
    fun findByTitleContaining(title: String): Flux<Book>
}

// BookController.kt（WebFlux控制器）
@RestController
@RequestMapping("/api/books")
class BookController(private val repository: BookRepository) {

    @GetMapping
    fun getAllBooks(): Flux<Book> = repository.findAll()

    @PostMapping
    @ResponseStatus(HttpStatus.CREATED)
    fun createBook(@RequestBody book: Mono<Book>): Mono<Book> = 
        book.flatMap { repository.save(it) }
}

# 构建阶段
FROM gradle:8.5-jdk21 AS builder
WORKDIR /app
COPY . .
RUN gradle bootJar --no-daemon

# 运行阶段
FROM openjdk:21-slim
WORKDIR /app
COPY --from=builder /app/build/libs/*.jar app.jar
CMD ["java", "-jar", "app.jar"]

stages:
  - build
  - test
  - deploy

build:
  image: gradle:8.5-jdk21
  script:
    - gradle build
  artifacts:
    paths:
      - build/libs/*.jar

test:
  image: gradle:8.5-jdk21
  script:
    - gradle test jacocoTestReport
  coverage: '/^Line Coverage: (\d+\.\d+)%/'

deploy:
  image: google/cloud-sdk:422.0.0
  script:
    - gcloud auth configure-docker
    - docker build -t gcr.io/$PROJECT_ID/book-service:$CI_COMMIT_SHORT_SHA .
    - docker push gcr.io/$PROJECT_ID/book-service:$CI_COMMIT_SHORT_SHA
    - helm upgrade --install book-service charts/book-service --set image.tag=$CI_COMMIT_SHORT_SHA
  environment:
    name: production
    url: https://bookstore.example.com
  only:
    - main

// OpenAI客户端配置
@Configuration
public class OpenAIConfig {
    @Bean
    public OpenAI openAI() {
        return OpenAI.builder()
            .apiKey(System.getenv("OPENAI_API_KEY"))
            .build();
    }
}

// 推荐服务实现
@Service
public class RecommendationService {
    private final OpenAI openAI;

    public List<Book> generateRecommendations(String userId) {
        var prompt = "为用户" + userId + "推荐3本计算机科学领域的书籍";
        var completion = openAI.chatCompletions()
            .chatCompletionRequest(ChatCompletionRequest.builder()
                .model("gpt-4-1106-preview")
                .messages(List.of(
                    ChatMessage.ofSystem("你是一个专业的图书推荐系统"),
                    ChatMessage.ofUser(prompt)
                ))
                .build())
            .execute();
        
        // 解析回复并转换为图书列表
        return parseRecommendations(completion.choices().get(0).message().content());
    }
}

// 添加Micrometer依赖
implementation("io.micrometer:micrometer-registry-prometheus")

// 配置自定义指标
@Bean
MeterRegistryCustomizer<MeterRegistry> configurer(
        @Value("${spring.application.name}") String applicationName) {
    return (registry) -> registry.config().commonTags("application", applicationName);
}

spring:
  sleuth:
    sampler:
      probability: 1.0  # 采样率100%
  zipkin:
    base-url: http://zipkin-server:9411/