如何用Spring替换已弃用的Corda节点Jetty Web服务器并兼容Corda自定义类

我之前在迁移Corda节点Web服务的时候也碰到过这个问题，完全理解弃用Jetty后要切换到Spring的痛点，下面是我总结的一套可行方案，既能替换掉旧的Jetty服务器，还能让Spring容器完美识别你自定义的ContractState、Contract、Flow这些Corda专属类：

1. 调整项目结构与依赖配置 #

首先你需要把Spring Web模块和Corda节点项目整合起来：

• 可以单独创建一个Spring Boot子模块，或者在现有Corda节点项目中直接添加Spring依赖。
• 在build.gradle中引入Spring Boot Web核心依赖，同时保证Corda相关依赖版本和你的节点一致：

dependencies {
    // Spring Boot Web核心依赖
    implementation 'org.springframework.boot:spring-boot-starter-web'
    // Corda节点核心依赖（替换为你的Corda版本，比如4.9）
    implementation 'net.corda:corda-node:4.9'
    implementation 'net.corda:corda-core:4.9'
}

2. 让Spring容器识别Corda专属类 #

这是核心需求，有两种可靠的方式实现：

方式一：指定包扫描路径 #

在Spring Boot启动类上添加@ComponentScan注解，把你的Corda应用类所在的包和Spring Web类的包都包含进去，这样Spring会自动扫描并管理这些类：

@SpringBootApplication
@ComponentScan(basePackages = {"com.your.corda.app", "com.your.spring.web"})
public class CordaSpringWebApplication {
    public static void main(String[] args) {
        SpringApplication.run(CordaSpringWebApplication.class, args);
    }
}

注意：com.your.corda.app是你存放ContractState、Contract、Flow等自定义类的包路径，替换成实际路径即可。

方式二：利用Corda注解的兼容性 #

如果你的Corda类使用了@CordaService注解，它本身就兼容Spring的@Component注解，只要扫描路径覆盖到这些类，Spring就能自动识别并纳入容器管理。

另外，你需要把Corda节点的服务实例注入到Spring容器中，方便Web层调用Corda功能。可以写一个配置类：

@Configuration
public class CordaNodeConfig {
    @Bean
    public CordaRPCOps cordaRPCOps() {
        // 连接到本地或远程Corda节点，替换为你的节点地址和账号密码
        CordaRPCClient client = new CordaRPCClient(new NetworkHostAndPort("localhost", 10006));
        CordaRPCConnection connection = client.start("user1", "test");
        return connection.getProxy();
    }
}

如果是嵌入式节点场景，也可以通过NodeBuilder构建节点并获取NodeServices实例注入到Spring中。

3. 禁用原有Jetty服务器，由Spring接管Web服务 #

找到Corda节点的node.conf配置文件，把原有Jetty服务器的配置禁用：

# 关闭Corda自带的Jetty服务器
webServer {
    enabled = false
}

之后启动Spring Boot应用，Spring默认的Tomcat服务器就会接管Web服务，你可以在Spring中编写Controller来处理前端请求，调用Corda的Flow、查询Vault中的状态等。

举个简单的Controller示例：

@RestController
@RequestMapping("/api/corda")
public class CordaController {
    @Autowired
    private CordaRPCOps cordaRPCOps;

    // 查询自定义ContractState
    @GetMapping("/states")
    public List<StateAndRef<YourCustomState>> getCustomStates() {
        return cordaRPCOps.vaultQuery(YourCustomState.class).getStates();
    }

    // 触发自定义Flow
    @PostMapping("/initiate-flow")
    public String initiateFlow(@RequestBody FlowRequest request) {
        try {
            cordaRPCOps.startFlowDynamic(YourCustomFlow.class, request.getTargetParty(), request.getAmount())
                    .getReturnValue()
                    .get();
            return "Flow initiated successfully";
        } catch (Exception e) {
            return "Error initiating flow: " + e.getMessage();
        }
    }
}

4. 测试验证 #

启动Spring Boot应用后，通过Postman或浏览器访问你的API接口：

• 访问GET http://localhost:8080/api/corda/states，应该能返回你自定义的ContractState数据。
• 调用POST http://localhost:8080/api/corda/initiate-flow，应该能成功触发Corda Flow。

如果以上步骤都正常运行，说明你已经成功替换了Corda的Jetty服务器，并且Spring容器能完美识别所有Corda专属类了。

内容的提问来源于stack exchange，提问作者Ahmed Shareef