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,实际实施需根据生产环境网络拓扑和安全策略调整。