别再纸上谈兵了!手把手教你在 Spring Boot 中落地 OpenClaw(Java 实战)

http://localhost:18789/v1/chat/completions

curl -fsSL https://openclaw.ai/install.sh | bash

openclaw setup

~/.openclaw/openclaw.json

export OPENCLAW_GATEWAY_TOKEN=xxxxx

<dependency>    
<groupId>org.springframework.boot</groupId>    
<artifactId>spring-boot-starter-web</artifactId></dependency><dependency>    
<groupId>org.springframework.boot</groupId>    
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

/src/main/java
└── com/icoderoad/ai
    ├── controller
    │   └── OpenClawController.java
    ├── service
    │   └── OpenClawService.java
    ├── config
    │   └── OpenClawConfig.java
    └── model
        ├── OpenClawRequest.java
        ├── OpenClawResponse.java
        └── Message.java

package com.icoderoad.ai.model; 
 public class Message { 
     private String role;     
 private String content; 
     public Message() {} 
     public Message(String role, String content) 
 {         
 this.role = role;         
 this.content = content;    
 } 
     // getter / setter }

package com.icoderoad.ai.model; 
 import java.util.List; 
 public class OpenClawRequest 
 { 
     private String model;     
 private List<Message> messages; 
     // getter / setter 
 }

package com.icoderoad.ai.model;
public class OpenClawResponse {
    private String id;
    private String model;
    private Choice[] choices;
    public static class Choice {
        private Message message;
        // getter / setter
    }
    // getter / setter
}

package com.icoderoad.ai.config;
@Configuration
public class OpenClawConfig {
    @Bean
    public RestClient openClawRestClient(
            RestClient.Builder builder,
            @Value("${openclaw.base-url}") String baseUrl,
            @Value("${openclaw.auth-token}") String token
    ) {
        return builder
                .baseUrl(baseUrl)
                .defaultHeaders(headers -> {
                    headers.add(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
                    if (token != null && !token.isEmpty()) {
                        headers.add(HttpHeaders.AUTHORIZATION, "Bearer " + token);
                    }
                })
                .build();
    }
}

package com.icoderoad.ai.service;
@Service
public class OpenClawService {
    private final RestClient restClient;
    public OpenClawService(RestClient restClient) {
        this.restClient = restClient;
    }
    public OpenClawResponse chat(String userInput) {
        OpenClawRequest request = new OpenClawRequest();
        request.setModel("gpt-4o");
        request.setMessages(List.of(
                new Message("user", userInput)
        ));
        return restClient.post()
                .uri("/v1/chat/completions")
                .body(request)
                .retrieve()
                .body(OpenClawResponse.class);
    }
}

package com.icoderoad.ai.controller;
@RestController
@RequestMapping("/ai")
public class OpenClawController {
    private final OpenClawService openClawService;
    public OpenClawController(OpenClawService openClawService) {
        this.openClawService = openClawService;
    }
    @PostMapping("/chat")
    public ResponseEntity<String> chat(@RequestBody ChatRequest request) {
        OpenClawResponse response = openClawService.chat(request.getMessage());
        if (response != null &&
            response.getChoices() != null &&
            response.getChoices().length > 0) {
            return ResponseEntity.ok(
                    response.getChoices()[0]
                            .getMessage()
                            .getContent()
            );
        }
        return ResponseEntity.internalServerError()
                .body("OpenClaw returned empty response");
    }
    public static class ChatRequest {
        private String message;
        // getter / setter
    }
}

POST /ai/chat

@GetMapping("/stream")
public SseEmitter stream(@RequestParam String message) {
    SseEmitter emitter = new SseEmitter(30_000L);
    executor.submit(() -> {
        // 使用 WebClient 订阅 OpenClaw 的流式响应
        // 将 token 按段发送给前端
    });
    return emitter;
}