최근 인터넷 기술의 급속한 발전으로 인해 기업은 데이터 양이 증가하고 있으며 기존의 중앙 집중식 메시지 대기열은 분산 시스템의 요구 사항을 충족할 수 없는 경우가 많습니다. 따라서 기업에서는 분산 메시지 라우팅 시스템을 점점 더 선호하고 있습니다. 우려.
이 글에서는 두 가지 오픈 소스 프레임워크인 go-zero와 Apache Camel을 사용하여 고성능 분산 메시지 라우팅 시스템을 구현하는 방법을 소개합니다.
1. go-zero 소개
go-zero는 많은 구성 요소(RPC, API, 캐시, 로그 등)를 통합하는 마이크로서비스 프레임워크로, 높은 성능을 빠르게 구축할 수 있는 풍부한 라이브러리와 도구를 제공합니다. 가용성, 고성능, 유지 관리가 쉬운 분산 시스템.
go-zero의 주요 기능은 다음과 같습니다.
1. gRPC 기반: protobuf를 사용하여 인터페이스를 정의하고 Go, Java, Python 등 여러 언어를 지원합니다.
2. 자동 생성 코드: 정의된 proto 파일을 기반으로 모델 및 서비스 코드를 자동으로 생성합니다.
3. 다중 데이터 저장 지원: MySQL, Redis, MongoDB 및 기타 데이터 저장 방법을 지원합니다.
4. 내장 캐시: 내장 Memcached 및 Redis, 캐시 읽기-쓰기 분리, 다중 레벨 캐시 등 지원
5. 경량: 다른 프레임워크에 비해 go-zero는 코드 양이 매우 적고 학습 곡선이 낮으며 사용하기 매우 편리합니다.
2. Apache Camel 소개
Apache Camel은 다양한 애플리케이션의 다양한 구성 요소를 연결하는 데 사용할 수 있는 오픈 소스 규칙 기반 라우팅 및 조정 프레임워크입니다.
Camel의 주요 특징은 다음과 같습니다.
1. 확장 용이성: Camel은 많은 구성 요소로 설계되었으며, 기존 라우터 및 데이터 변환기는 새로운 구성 요소를 추가하여 쉽게 확장할 수 있습니다.
2. 다중 언어 지원: Java, C#, C++, Python, Scala, Ruby 등 다양한 언어와 프로토콜 간의 상호 작용을 지원합니다.
3. 경량: 다른 프레임워크에 비해 Camel은 코드 양이 매우 적고 학습 곡선이 낮으며 사용하기 매우 편리합니다.
4. 다중 데이터 소스 지원: MQ, HTTP, JMS, TCP, FTP 등 다양한 데이터 소스 간의 변환을 지원합니다.
3. go-zero와 Apache Camel의 조합 실습
go-zero를 사용하여 메시지 라우팅, 데이터 변환 등 다양한 요청을 처리하는 RPC 서버를 구축했습니다. Apache Camel은 데이터 변환 및 라우팅을 담당합니다.
이 서버 측에서는 go-zero의 모델 및 서비스 자동 생성 도구를 사용하여 메시지 라우팅 및 데이터 변환 서비스를 생성합니다. 이러한 서비스는 gRPC 통신 프레임워크를 기반으로 하며 인터페이스는 protobuf를 사용하여 정의됩니다.
다음으로 Camel을 사용하여 라우팅 및 데이터 변환 기능을 구현하겠습니다. 라우팅을 위해 Camel의 라우팅 엔진을 사용하여 메시지를 대상 서비스로 라우팅합니다. 데이터 변환을 위해 Camel에서 제공하는 다양한 데이터 변환기를 사용하여 메시지를 타겟 형식으로 변환한 후 타겟 시스템으로 전송합니다.
이 분산 메시지 라우팅 시스템의 구성 프로세스를 더 잘 보여주기 위해 간단한 예를 들어 설명하겠습니다.
먼저 시나리오가 있습니다. 주문 관리 시스템은 처리를 위해 주문 정보를 ERP 시스템으로 보내야 합니다. 다음 기능을 구현해야 합니다.
1. 주문 관리 시스템에서 주문 메시지를 받습니다.
2. 주문 메시지를 ERP 시스템에서 인식할 수 있는 형식으로 변환합니다.
3. 변환된 주문 메시지를 ERP 시스템으로 라우팅합니다.
이러한 기능을 구현하려면 다음을 수행하세요.
1. go-zero를 사용하여 주문 관리 시스템에서 주문 메시지를 받을 RPC 서버를 구축합니다.
2. Camel에서 제공하는 JMS 컴포넌트를 메시지 미들웨어로 사용하여 주문 메시지를 ERP 시스템에 전송합니다.
3. Camel의 데이터 변환기를 사용하여 주문 메시지를 ERP 시스템에서 인식할 수 있는 형식으로 변환합니다.
4. 변환된 주문 메시지를 ERP 시스템으로 라우팅하는 Camel 라우팅 규칙을 정의합니다.
이제 구체적인 구현 단계를 살펴보겠습니다.
먼저 go-zero에서 protobuf 인터페이스와 데이터 모델을 정의합니다.
syntax = "proto3";
package order;
option go_package = "order";
message OrderInfo {
string orderId = 1;
string customerName = 2;
string address = 3;
string phone = 4;
}
service OrderService {
// 接收订单信息
rpc SubmitOrder(OrderInfo) returns (Empty) {}
}go-zero 자동 생성 도구를 사용하여 모델 및 서비스 코드를 생성합니다.
# 生成model make service.proto # 生成service make service
그런 다음 RPC 서버 측에서 SubmitOrder 메서드를 구현하여 수신합니다. 관리 시스템의 주문 메시지에서 주문:
func (s *Service) SubmitOrder(ctx context.Context, req *order.OrderInfo) (*status.Empty, error) {
orders := make([]string, 0)
orders = append(orders, req.OrderId)
orders = append(orders, req.CustomerName)
orders = append(orders, req.Address)
orders = append(orders, req.Phone)
// 通过RPC发送消息到消息中间件
go sendToMQ(orders)
return &status.Empty{}, nil
}
func sendToMQ(order []string) {
// 发送MQ消息
orderInfo := map[string]interface{}{
"orderId": order[0],
"customerName": order[1],
"address": order[2],
"phone": order[3],
}
fmt.Printf("Send to MQ: %v
", orderInfo)
message := &jms.TextMessage{
Body: fmt.Sprintf("%v", orderInfo),
}
err := producer.Send(message)
if err != nil {
fmt.Printf("Failed to send message: %v
", err)
}
}다음으로 Camel의 JMS 구성 요소를 사용하여 ActiveMQ 메시지 미들웨어에 연결합니다.
from("activemq:queue:order.queue").process(new Processor() {
public void process(Exchange exchange) throws Exception {
// 接收MQ消息，转换数据格式
Map<String, Object> orderInfo = new HashMap<String, Object>();
orderInfo = exchange.getIn().getBody(Map.class);
exchange.getIn().setBody(orderInfo);
}
});그런 다음 Camel의 데이터 변환기를 사용하여 주문 메시지를 ERP 시스템이 인식할 수 있는 형식으로 변환합니다.
from("activemq:queue:order.queue").process(new Processor() {
public void process(Exchange exchange) throws Exception {
// 接收MQ消息，转换数据格式
Map<String, Object> orderInfo = new HashMap<String, Object>();
orderInfo = exchange.getIn().getBody(Map.class);
// 数据转换
String json = "{"order_id": "" + orderInfo.get("orderId") + """ +
", "customer_name": "" + orderInfo.get("customerName") + """ +
", "address": "" + orderInfo.get("address") + """ +
", "phone": "" + orderInfo.get("phone") + """ +
"}";
exchange.getIn().setBody(json);
}
});마지막으로 변환된 주문 메시지를 ERP 시스템으로 라우팅하는 Camel 라우팅 규칙을 정의합니다.
from("activemq:queue:order.queue").process(new Processor() {
public void process(Exchange exchange) throws Exception {
// 接收MQ消息，转换数据格式
Map<String, Object> orderInfo = new HashMap<String, Object>();
orderInfo = exchange.getIn().getBody(Map.class);
// 数据转换
String json = "{"order_id": "" + orderInfo.get("orderId") + """ +
", "customer_name": "" + orderInfo.get("customerName") + """ +
", "address": "" + orderInfo.get("address") + """ +
", "phone": "" + orderInfo.get("phone") + """ +
"}";
exchange.getIn().setBody(json);
}
}).to("http://erp.com/order");위 코드에서는 Camel의 라우팅 엔진과 데이터 변환기를 사용하여 주문 메시지를 ERP 시스템 중간으로 변환하고 라우팅합니다.
4. 요약
이 글에서는 두 가지 오픈 소스 프레임워크인 go-zero와 Apache Camel을 사용하여 고성능 분산 메시지 라우팅 시스템을 구현하는 방법을 소개합니다. go-zero와 Camel의 기능과 장점을 활용하면 고성능, 고가용성, 손쉬운 유지 관리 기능을 갖춘 분산 메시지 라우팅 시스템을 더욱 효과적으로 개발할 수 있어 기업에 더 큰 가치를 제공할 수 있습니다.
위 내용은 Go-Zero와 Apache Camel의 결합 사례: 고성능 분산 메시지 라우팅 시스템 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
