Easy-Ms-Mq

pom.xml:
    <!-- 可以直接把easy-ms-parent当做parent，或者当引入多个easy-ms组件时使用parent可以只需设置一次版本号 -->
    <parent>
        <groupId>com.stars.easyms</groupId>
        <artifactId>easy-ms-parent</artifactId>
        <version>${easy-ms.version}</version>
    </parent>
		
    <!-- 如果是直接引入easy-ms，则不需要引入easy-ms-mq，easy-ms已经默认依赖了easy-ms-mq -->
    <dependencies>
        <dependency>
            <groupId>com.stars.easyms</groupId>
            <artifactId>easy-ms-mq</artifactId>
        </dependency>
    </dependencies>

    <!-- 如果是直接引入easy-ms，则不需要引入easy-ms-mq，easy-ms已经默认依赖了easy-ms-mq -->
    <dependencies>
        <dependency>
            <groupId>com.stars.easyms</groupId>
            <artifactId>easy-ms-mq</artifactId>
            <version>${easy-ms.version}</version>
        </dependency>
    </dependencies>

@MQManager
public class MQDemoManager {

    @MQSender(key = "test_dev", name = "发送端demo")
    public void send(UserInfo userInfo) {
        // Intentionally blank
    }
    
}

@Service
public class EasyMsMQDemoService implements RestService<BaseInput, BaseOutput> {

    @Autowired
    private MQDemoManager mqDemoManager;

    @Override
    public BaseOutput execute(BaseInput input) {
        UserInfo userInfo = new UserInfo();
        userInfo.setName("小明");
        userInfo.setAge(10);
        mqDemoManager.send(userInfo);
        return new BaseOutput();
    }
}

@MQManager
public class MQDemoManager {

    @Autowired
    private UserInfoService userInfoService;
  
  	/**
     * key可以使用${}表达式，使用spring.mq.key.test=test_dev的方式配置
     * 接收的参数需要跟注解的batch对应，默认是开启批量，因此需要接收时的参数为List类型，若未开启批量则接收类型为UserInfo
     */
    @MQReceiver(key = "${test}", name = "接收端demo")
    public BatchResult receive(List<UserInfo> userInfoList) {
        userInfoService.test(userInfoList);
        return BatchResult.ofSuccess(userInfoList);
    }

}

@Service
public class UserInfoService {

  	/**
     * 处理逻辑
     */
    public void test(List<UserInfo> userInfoList) {
        for (UserInfo userInfo : userInfoList) {
            System.out.println(userInfo.getName() + ":" + userInfo.getAge());
        }
    }

}