Java使用消息队列还是直接使用线程池ExecutorService异步处理？

Question

说说这两种的区别，各自适合什么场景？

用线程池ExecutorService异步处理：我理解ExecutorService其实也是内部使用了队列（如LinkedBlockingQueue），所以从设计上，其实和使用中间价的消息队列是差不多一致的。只是这里应用服务器既充当生产者又充当消费者，也是消息队列中间价的实现者。这种应该适合非分布式的架构，比如简单的只有一台服务器。

使用消息队列：消息队列（指activeMQ，rabbitMQ，kafaKa，Redis等）因为一般都是中间件，部署在其他机器，需要一定的网络消耗。
本着解耦的目的，使用后者更合理，因为应用服务器一般内存也不会太多，队列长度不易太长。让应用服务器只处理逻辑比较合理。适合分布式架构。

1.使用JDK提供的异步框架ExecutorService。

threadPool.execute(new Runnable() {
    @Override
    public void run() {
        // 这里是异步处理的，比较耗时的逻辑，比如数据库操作
        userService.setDefaultAddressId(user.getUserId(), bookingForm.getAddressId());
    }
});

2.将消息发送到消息队列，如使用redis的List简单实现，然后后台线程消费消息。

// 生产消息
redisTemplate.opsForList().leftPush(LOG_MQ_KEY, JsonUtil.beanToJson(httpRequestLog));

// 后台线程异步消费消息
String popValue = redisTemplate.opsForList().rightPopAndLeftPush(LOG_MQ_KEY, TEMP_LOG_MQ_KEY);

Answer 1

尽量用ExecuteService，如果不是涉及到： 跨服务业务。比如订单、支付 业务去耦合。比如有些情况上级业务不用知道下级执行是否成功，比如log日志等 使用Mq会带来设计上的复杂性：网络抖动怎么办？最大队列长度怎么设置？超时时间又设置多少？Qos又设置为多少？消费者多少个比较合适？channel cache size又该设置为多少？业务线可能都是用同一个Mq，你占资源太多，或者设计不当导致整个Mq故障（比如你不确认消息），开发同志们难道不来撕你么？ 为什么非要多加个组件呢？能不用尽量不用