So verwenden Sie MassTransit Response ⇐ C#

[Guest]

Projekt
Version



Bereitstellen

Code: Select all

/// Program
builder.Services.AddMassTransit(x =>
{
//x.AddConsumer();
//将请求发送到指定地址，
x.AddRequestClient();

x.UsingInMemory((context, cfg) =>
{

cfg.ConfigureEndpoints(context);
});

});

/// Controllor
[Route("api/[controller]")]
[ApiController]
public class RequestController : ControllerBase
{
IRequestClient _client;

public RequestController(IRequestClient client)
{
_client = client;
}

[HttpGet("{orderId}")]
public async Task Get(string orderId, CancellationToken cancellationToken)
{
//var response = await _client.GetResponse(new { orderId }, cancellationToken);
return Ok(response.Message);
}
}

Consumer

Code: Select all

/// Program

builder.Services.AddMassTransit(x =>
{
x.AddRequestClient();

x.UsingInMemory((context, cfg) =>
{
cfg.ConfigureEndpoints(context);
});
});
/// Consumer
public class CheckOrderStatusConsumer :
IConsumer
{

public async Task Consume(ConsumeContext context)
{
await context.RespondAsync(new
{
OrderId = "11111",
});
}
}

Ziel: Ich möchte Klassen zwischen zwei WebApi-Projekten abrufen

Code: Select all

 //x.AddConsumer();

Dieser Code fordert nach dem Kommentieren eine Zeitüberschreitung an
Das Abbrechen der Anmerkung kann normal ausgeführt werden
Es tut mir leid, ich kann kein Englisch . Ich habe Fragen über einen Übersetzer gestellt
Ich bin Autodidakt und es kann zu unklaren Ausdrücken oder mangelndem Verständnis von Geschäftsprozessen kommen. Bitte vergib mir