向微服务发送异步消息

Question

我有一个BE服务a，它正在使用假客户端向microservice B发送Rest JSON消息：

@FeignClient(name = "mail-service")
@LoadBalancerClient(name = "mail-service", configuration = LoadBalancerConfiguration.class)
public interface EmailClient {

    @RequestMapping(method = RequestMethod.POST, value = "/engine/emails/register")
    void setUserRegistration(CreateUserDTO createUserDTO);
}

终点：

@RestController
@RequestMapping("/emails")
public class EmailController {

    @RequestMapping(method = RequestMethod.POST, value = "/register", consumes = MediaType.APPLICATION_JSON_VALUE)
    public ResponseEntity<?> register(@Valid @RequestBody CreateUserDTO createUserDTO) {

        emailRestService.processCreateUserMessage(createUserDTO);
        // Implementation of service to send mail to AWS SES
        return new ResponseEntity<>(HttpStatus.OK);
    }
}

Rest Endpoint正在向AWS Ses邮件或其他邮件提供商发送邮件。

问题是来自飞格的第一个呼叫可能需要5秒或更长时间。我需要使其异步，以便FE客户端不要等待邮件发送。

我如何可以使从飞度异步发出的Rest调用到超文本传输协议响应OK没有等待时间可以预期？是否有一些更好的解决方案来实现这一点？

Answer 1

好了，Faign不允许非阻塞IO，这是一项正在进行的工作。

但是您可以实现EmailRestServiceasync。考虑以下代码（我不知道processCreateUserMessage是否也负责发送电子邮件，但如果需要，建议的解决方案应该可以扩展到该功能）：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

//...

@Service
public class EmailRestServiceImpl implements EmailRestService {
  //...
  
  @Async
  public void processCreateUserMessage(CreateUserDTO createUserDTO) {
    // Implementation of service to send mail to AWS SES
    // ...
  }

}

请注意@Async注释定义。

要启用Spring异步处理，您需要在主配置或特定配置中定义@EnableAsync注释：

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;

@Configuration
@EnableAsync
public class AsyncConfiguration {

}

无需更改您的Controller，尽管如果您愿意，您可以返回更方便的HTTP状态代码：

@RestController
@RequestMapping("/emails")
public class EmailController {

    @RequestMapping(method = RequestMethod.POST, value = "/register", consumes = MediaType.APPLICATION_JSON_VALUE)
    public ResponseEntity<?> register(@Valid @RequestBody CreateUserDTO createUserDTO) {
        // Will be executed asynchronously and return immediately
        emailRestService.processCreateUserMessage(createUserDTO);
        return new ResponseEntity<>(HttpStatus.ACCEPTED);
    }
}