Java两个系统如何实现通信

系统通信的核心机制

同步通信（请求-响应模式）

• 特点：实时性强，调用方等待结果返回
• 应用场景：支付确认、库存扣减等需要即时响应的操作
• 技术栈： // 使用Spring Boot的RestTemplate示例 @RestController public class ClientController { @GetMapping("/call") public String callSystemB() { RestTemplate restTemplate = new RestTemplate(); ResponseEntity<String> response = restTemplate.getForEntity( "http://system-b:8080/api/data", String.class ); return "SystemB返回: " + response.getBody(); } }

异步通信（事件驱动模式）

• 特点：解耦性强，支持削峰填谷

• 应用场景：日志处理、订单状态更新、通知推送

  

• 技术栈：

  // RabbitMQ生产者示例（Spring AMQP） @Service public class MessageSender { @Autowired private RabbitTemplate rabbitTemplate; public void sendOrderEvent(Order order) { rabbitTemplate.convertAndSend( "orderExchange", "order.created", order ); } }

主流通信方案详解

方案1：HTTP/RESTful API

• 实现原理：基于TCP的应用层协议
• 优势：标准化、跨语言、易调试
• 安全加固：
  • HTTPS加密传输
  • OAuth2.0/JWT认证 # Spring Security配置片段 security: oauth2: resourceserver: jwt: issuer-uri: https://auth-server/

方案2：RPC框架（gRPC/Dubbo）

• 性能对比：

  | 框架 | 协议 | 吞吐量 | 适用场景 |

  |———|———–|———|——————|

  | gRPC | HTTP/2 | 50K+ QPS | 高性能微服务 |

  | Dubbo| 自定义TCP | 40K+ QPS | 企业级分布式系统 |

• gRPC示例：

  

  // 定义Proto文件 service UserService { rpc GetUser (UserRequest) returns (UserResponse); } // Java服务端实现 public class UserServiceImpl extends UserServiceGrpc.UserServiceImplBase { @Override public void getUser(UserRequest request, StreamObserver<UserResponse> responseObserver) { UserResponse response = UserResponse.newBuilder() .setId(request.getId()) .setName("用户"+request.getId()) .build(); responseObserver.onNext(response); responseObserver.onCompleted(); } }

方案3：消息队列

• 选型对比：

  | 中间件 | 时延 | 可靠性 | 特色功能 |

  |———–|——–|——–|————————|

  | Kafka | 毫秒级 | | 高吞吐、日志溯源 |

  | RabbitMQ | 微秒级 | | 灵活路由、死信队列 |

  | RocketMQ | 毫秒级 | | 事务消息、顺序消息 |

• Kafka消费示例：

  

  @KafkaListener(topics = "user-events") public void handleEvent(ConsumerRecord<String, UserEvent> record) { UserEvent event = record.value(); System.out.println("处理事件: " + event.getType()); }

方案4：WebSocket（双向通信）

• 适用场景：实时聊天、监控大屏

• 服务端实现：

  @ServerEndpoint("/chat/{systemId}") public class ChatEndpoint { @OnOpen public void onOpen(Session session, @PathParam("systemId") String id) { // 新连接注册 } @OnMessage public void onMessage(String message, Session session) { // 转发消息到目标系统 session.getBasicRemote().sendText("ECHO: " + message); } }

架构选型决策树

graph TD A[是否需要实时响应？] -->|是| B{数据一致性要求} A -->|否| C[选择消息队列] B -->|强一致| D[RPC框架] B -->|最终一致| C A -->|双向流| E[WebSocket]

企业级实践建议

1. 熔断降级：通过Resilience4j实现服务保护 CircuitBreaker circuitBreaker = CircuitBreaker.ofDefaults("systemB"); Supplier<String> decorated = CircuitBreaker.decorateSupplier(circuitBreaker, () -> callSystemB());
2. 链路追踪：集成SkyWalking可视化调用链
3. 性能优化：
   • HTTP使用连接池（Apache HttpClient）
   • Protobuf替代JSON提升序列化效率
4. 安全保障：
   • 消息队列TLS加密传输
   • RPC调用启用mTLS双向认证

典型场景案例

电商系统交互流程：

1. 订单服务（Java）HTTP同步调用库存服务扣减库存
2. 支付成功后通过RabbitMQ异步通知订单更新状态
3. 物流服务通过gRPC获取订单详情
4. 客服系统通过WebSocket推送物流状态到用户端

引用说明

1. Spring RestTemplate 文档
2. gRPC官方Java教程
3. Apache Kafka快速入门
4. WebSocket RFC规范
5. OAuth2.0安全协议

   遵守CC BY-SA 4.0许可协议，技术方案更新于2025年Q3，关键组件版本：Spring Boot 3.x, gRPC 1.54, Kafka 3.4,实际实施需根据生产环境网络拓扑和安全策略调整。