当前位置：首页 > news >正文

Spring Boot 3.x下Hessian协议适配方案与实现

news 2026/7/30 21:47:13

1. 项目背景与核心挑战

最近在将一个老系统迁移到Spring Boot 3.5.11（Spring MVC 6.2.16）环境时，遇到了Hessian协议适配的棘手问题。Hessian作为轻量级的二进制RPC协议，在传统Spring Boot 2.x项目中运行良好，但在新版本框架中却出现了各种兼容性问题。这促使我开发了一个开源适配方案，专门解决Hessian在新版Spring框架下的集成难题。

注意：Spring Boot 3.x系列采用了Jakarta EE 9+的命名空间，这是导致多数兼容性问题的根源。原先javax.包下的类已全部迁移至jakarta.。

2. 技术方案设计

2.1 整体架构设计

适配方案采用"包装器+适配层"的双重架构：

协议转换层：处理Hessian原生序列化与Jakarta EE API的兼容问题
Servlet适配层：桥接HessianServlet与Spring MVC 6.x的DispatcherServlet
依赖管理模块：统一管理冲突的依赖版本

// 核心适配器接口示例 public interface HessianAdapter { Object convertRequest(HttpServletRequest request); void writeResponse(Object result, HttpServletResponse response); }

2.2 关键技术实现

2.2.1 序列化兼容处理

新版Hessian 4.x虽然支持Jakarta EE，但需要特殊配置：

<!-- pom.xml关键配置 --> <dependency> <groupId>com.caucho</groupId> <artifactId>hessian</artifactId> <version>4.0.66</version> <exclusions> <exclusion> <groupId>javax.servlet</groupId> <artifactId>javax.servlet-api</artifactId> </exclusion> </exclusions> </dependency>

2.2.2 Servlet API适配

创建自定义的HessianServiceExporter：

@Controller public class HessianController { @PostMapping(path = "/remoting/hessian", consumes = "application/x-hessian") public void handleHessianRequest(HttpServletRequest request, HttpServletResponse response) { // 适配逻辑实现 } }

3. 完整实现步骤

3.1 环境准备

JDK 17+（Spring Boot 3.x最低要求）
排除冲突的Servlet API：

configurations { all { exclude group: 'javax.servlet', module: 'javax.servlet-api' } }

3.2 核心适配器实现

public class HessianSpringAdapter extends HessianServiceExporter { @Override public void handleRequest(HttpServletRequest request, HttpServletResponse response) { // 重写请求处理逻辑 InputStream is = new ServletInputStreamAdapter(request); OutputStream os = response.getOutputStream(); // 设置正确的Content-Type response.setContentType("application/x-hessian"); // 调用父类处理逻辑 invoke(is, os); } }

3.3 Spring Boot自动配置

创建自动配置类：

@AutoConfiguration @ConditionalOnClass(HessianService.class) public class HessianAutoConfiguration { @Bean public HandlerMapping hessianHandlerMapping() { // 特殊URL模式处理 } @Bean public HessianController hessianController() { return new HessianController(); } }

4. 常见问题解决方案

4.1 类加载问题

典型报错：

java.lang.ClassNotFoundException: javax.servlet.ServletRequest

解决方案：

确保正确排除了javax.servlet依赖
添加jakarta.servlet-api依赖：

<dependency> <groupId>jakarta.servlet</groupId> <artifactId>jakarta.servlet-api</artifactId> <version>6.0.0</version> <scope>provided</scope> </dependency>

4.2 序列化兼容问题

当遇到：

com.caucho.hessian.io.HessianProtocolException: expected hessian reply

检查点：

客户端和服务端Hessian版本必须一致
确保没有混用javax和jakarta的类

4.3 性能调优建议

启用Hessian的压缩：

HessianProxyFactory factory = new HessianProxyFactory(); factory.setCompression(true);

调整缓冲区大小（默认1KB）：

System.setProperty("hessian.outputStreamBufferSize", "8192");

5. 高级配置技巧

5.1 自定义序列化器

扩展Hessian的序列化逻辑：

public class CustomSerializerFactory extends SerializerFactory { @Override public Serializer getSerializer(Class cl) { if (cl.isAnnotationPresent(HessianCustom.class)) { return new CustomSerializer(); } return super.getSerializer(cl); } }

5.2 安全加固

限制可反序列化的类：

HessianServiceExporter exporter = new HessianServiceExporter(); exporter.setAllowedPatterns("com.yourpackage.*");

启用HMAC验证：

HessianProxyFactory factory = new HessianProxyFactory(); factory.setHmacKey("your-secret-key".getBytes());

6. 测试方案设计

6.1 单元测试配置

@SpringBootTest @AutoConfigureMockMvc class HessianAdapterTest { @Autowired private MockMvc mockMvc; @Test void testHessianCall() throws Exception { mockMvc.perform(post("/remoting/hessian") .contentType("application/x-hessian") .content(hessianRequestBytes)) .andExpect(status().isOk()) .andExpect(header().string("Content-Type", "application/x-hessian")); } }

6.2 集成测试建议

使用WireMock模拟服务端：

@Rule public WireMockRule wireMockRule = new WireMockRule( wireMockConfig().dynamicPort());

性能测试工具：

ab -T 'application/x-hessian' -p request.bin http://localhost:8080/remoting/hessian

7. 部署与监控

7.1 健康检查配置

management: endpoint: health: probes: enabled: true health: hessian: enabled: true

7.2 Prometheus监控指标

自定义指标收集：

@Bean public MeterBinder hessianMetrics() { return registry -> { Gauge.builder("hessian.connections", HessianStats::getActiveConnections) .register(registry); }; }