MassTransit 동일한 대기열에 응답하여 루프가 발생합니다.

Question

현재 MassTransit에 대해 NServiceBus을 교환 중이며 요청/응답 패턴에 약간의 어려움이 있습니다.

에서 나는 Handler에 회신을 할 수 있으며이를 보낸 클라이언트로 돌아갑니다. 응답이 때문에 루프를 만드는에서 소비 된 것을 대기열로 다시 전송되는 것처럼 MassTransit에서

, 그것은 ... 나타납니다

이상한 것은, 내가 InMemory를 사용하여 버스를 만드는거야 경우, 그리고 같은 컴퓨터에서 클라이언트와 소비자 모두에게 문제가 없습니다.

나는 응답을 잡으려고 내 클라이언트를 기대하고 있지만, 대신 그 메시지 유형을받을 설치하지이기 때문에, 또한 홀수 내 Consumer 후비는 그것을는 ...

나는 클라이언트에서 뭔가를 놓치고 있습니까 설정을 요청 하시겠습니까?

클라이언트 :

.... 
IRequestClient<IWorklistRequest, IWorklistResponse> client = CreateRequestClient(busControl, WorklistEndpointUri); 

Console.Write("Sending Request"); 

Task.Run(async() => 
{ 
    IWorklistRequest request = new WorklistRequest 
    { 
     CurrentDateFrom = new DateTime(2016, 11, 07) 
    }; 

    var response = await client.Request(request); 

    Console.WriteLine("Worklist Items retrieved: {0}", response.ExamItemList.Length); 

}).Wait(); 
.... 



static IRequestClient<IWorklistRequest, IWorklistResponse> CreateRequestClient(IBusControl busControl, string endpointAddress) 
{ 
    Console.WriteLine("Creating Request client..."); 

    var serviceAddress = new Uri(endpointAddress); 
    IRequestClient<IWorklistRequest, IWorklistResponse> client = 
    busControl.CreateRequestClient<IWorklistRequest, IWorklistResponse>(serviceAddress, TimeSpan.FromSeconds(10)); 

    return client; 
} 

소비자 :

public Task Consume(ConsumeContext<IWorklistRequest> context) 
    { 
     _log.InfoFormat("Received Worklist Request with Id: {0}", context.RequestId); 


     try 
     { 
      var result = _provider.GetAllWorklistsByStartDate(context.Message.CurrentDateFrom); 

      IWorklistResponse response = new WorklistResponse 
      { 
       ExamItemList = result.ToArray() 
      }; 

      // the below is sending the response right back to the original queue and is getting picked up again by this same consumer 
      context.Respond(response); 
     } 
     catch (Exception ex) 
     { 
      _log.Info(ex.Message); 
     } 

     return Task.FromResult(0); 
    } 

Answer 1

것은 당신이 RabbitMQ를 사용하고, 당신이 요청 클라이언트를 사용하는 경우, 당신은이 동작을 볼 수 없습니다해야 .

이는 MassTransit GitHub의 저장소에 요청 클라이언트를 사용하는 방법을 보여주는 샘플입니다 : https://github.com/MassTransit/Sample-RequestResponse이

위의 코드는 올바른 것으로 나타나고 Respond() 호출 요청 메시지의 응답 주소를 사용해야하는 임시 버스 주소로 보내는 직접 엔드 포인트입니다.

이 영역 주변에는 상당히 광범위한 단위 테스트 적용 범위가 있으며 위의 샘플은 최신 버전의 MassTransit으로 업데이트되고 확인되었습니다. RabbitMQ 가상 호스트 삭제/재 작성 및 처음부터 응용 프로그램 실행 (응답 서비스를 먼저 시작하여 끝점을 설정하는 방법)을 고려해보십시오.