이벤트 구동 ASP의 트렁크 모드입니다.NET 핵심 마이크로 서비스 구조

컨텐트

1. 생성합니다.NET 핵심 마이크로서비스 및 메시지 교환

정보 손실

C:\dev>docker stop some-rabbit

{
 "name": "Chris2",
 "mail": "[email protected]",
 "otherData": "Some other data"
}

2. 사무성 발송함 모델 실현

If you want to read about the details and concepts of the transactional outbox pattern, you can get more information about it at: https://microservices.io/patterns/data/transactional-outbox.html

UserServiceContext에 추가:

public DbSet<UserService.Entities.IntegrationEvent> IntegrationEventOutbox { get; set; }

사용자 컨트롤러 수정

PutUser 및 Positser의 코드에서 트랜잭션을 시작하고 사용자 엔티티를 업데이트/삽입합니다.같은 업무에서, 이벤트를 직접 발표하는 것이 아니라 데이터베이스에IntegrationEvent를 삽입합니다:

게시자를 Background Service로 만들기

IntegrationEventSenderService 데이터베이스 폴링 및 완료되지 않은 모든 이벤트를 RabbitMQ로 전송:

Continuously polling the database is not good. You will improve the polling in the next step.

Startup에 Integration EventSender Service를 Hosted Service로 추가합니다.정무사 사장:

추가 읽기: Implement background tasks in microservices with IHostedService and the BackgroundService class

3. (Optional) Test the Implementation

지금은 모든 것이 예상대로 실행되는지 테스트하기에 좋은 시기입니다:

사용자를 삭제합니다.발송함 표를 포함한 데이터베이스 모델을 만들 수 있도록

게시물을 삭제합니다.그래서 두 데이터베이스가 모두 비어 있습니다

RabbitMQ 컨테이너 시작:

C:\dev>docker start some-rabbit

Visual Studio에서 사용자 서비스 시작

Swagger UI를 사용하여 UserService에서 사용자 만들기:

{
 "name": "Chris",
 "mail": "[email protected]",
 "otherData": "Some other data"
}

이벤트의 발송이 콘솔에 기록됨:

RabbitMQ 컨테이너 중지:

C:\dev>docker stop some-rabbit

Swagger UI를 사용하여 UserService에 다른 사용자 만들기:

{
 "name": "Chris2",
 "mail": "[email protected]",
 "otherData": "Some other data"
}

Integration EventSender에서 메시지를 보낼 수 없으며, 5초마다 RabbitMQ 이상을 기록합니다:

PostService 시작(자동 재부팅 로직 없음)

RabbitMQ 컨테이너 시작:

C:\dev>docker stop some-rabbit

IntegrationEventSender 메시지 보내기:

축하합니다: 당신의 발송함이 정상적으로 작동하고 있습니다

3. Add Publisher Notify, Acknowledgments, and Resilient Message Handling

사용자 실체를 삽입하거나 업데이트하면 발표자에게 새로운 항목이 있을 때만 발송 박스 테이블에서 데이터를 불러올 수 있음을 알립니다.사용자 실체의 버전 필드는 소비자의 중복되거나 무질서한 정보를 처리할 수 있습니다.RabbitMQ 게시 서버 확인, 영구 메시지 및 게시 서버, 구독 서버 또는 이벤트 버스가 작동하지 않는 경우 확인

발송함 모드, 발표자 알림, 확인 및 버전 제어의 상세한 작업 절차:

You could use RowVersion with a production SQL database. But SQLite doesn’t support it.

IntegrationEventSender 수정

발송함에 새로운 항목이 있을 때CancelationToken을 사용하여 깨웁니다.제47, 49, 65 줄의 주석을 참고하여 지속적인 소식과 발표자가 확인하는 실현 방식을 이해하십시오

Synchronously waiting for publisher confirms is very inefficient. See the official RabbitMQ guide for how to improve it.

대기열을 영구 대기열로 만들었는지 확인하기:

Durable queues will be recovered on node boot, including messages in them published as persistent. Messages published as transient will be discarded during recovery, even if they were stored in durable queues. (https://www.rabbitmq.com/queues.html)

사용자 컨트롤러 수정

postaser/PutUser의 version 필드 설정/증가

구조 함수에서IntegrationEventSender를 가져오고 업무를 제출한 후에 호출합니다

수정 프로그램.서비스 후 프로젝트의 cs

• 제78행 자동 확인 사용하지 않음

• 75행 발송 확인

• 45행과 64행에서 중복 메시지가 있는지 확인

Using Program.Main is not optimal. You could move the code to a BackgroundService.

현재 사용자를 삭제하고 데이터베이스를 발표하며 이 안내서의 세 번째 부분에서 보여준 것처럼 사용자의 실현을 테스트할 수 있습니다

4. Final Thoughts and Outlook

이벤트 구동 체계 구조에 발송함 모드를 추가하여 더욱 탄력적으로 만듭니다

생산 환경에서 사용할 코드를 조정해야 합니다: 코드를 정리하고 안전한 모범 사례를 적용해야 합니다.신청NET 핵심 디자인 모드, 오류 처리 등. 게시자 확인을 최적화하고post 서비스에서 Background 서비스를 사용해야 합니다

보낸 편지함의 논리를 DbContext와 같은 중심 위치로 이동하거나 MassTransit 같은 프레임워크를 사용할 수 있습니다.(이 프레임, 전설 이야기와 축소/절분은 아마도 나의 다음 문장에 좋은 선택일 것이다.)

와 에 대한 다른 글을 참고하십시오