redis和mq异步写说明文档.md 2.12 KB

Redis

YHValueOperations.set()方法改成异步写,首先写入jvm queue,然后异步请求redis。 同时新增提供一个同步请求的set方法 syncSet(), 如果想走同步set可以调用此方法。

调用期间可能出现队列满了,或者超时(默认2s),会丢弃,打印相应的日志,级别是error,想要进行配置. \ 下面是对应的logger : \ private final Logger logger = LoggerFactory.getLogger(AsynRedisTemplate.class);

配置开关

  • 全局开关:在global.properties里配置 yoho.core.redis.async.enable 默认值为true (异步写), 配置为false为同步写
  • 单个bean开关:默认为true(异步写), 配置为false为同步写, 具体配置范例为: ```
也可以这样配置


## Mq
YhProducerTemplate.send()方法改成异步发送消息,首先写入jvm queue,然后异步请求mq

> 调用期间可能出现队列满了,或者超时(默认2s),会丢弃,打印相应的日志,级别是error,需要进行配置。\
下面是对应的logger:\
``` private final Logger asynclogger = LoggerFactory.getLogger("asyncproducer"); ```  \ 
日志会打印出丢弃的消息全部信息,包括请求体json字符串

#### 配置开关
- 全局开关:在global.properties里配置 yoho.core.redis.async.enable
    默认值为true (异步写), 配置为false为同步写
- 单个bean开关:默认为true(异步写),  配置为false为同步写, 具体配置范例为:

<!--发送消息 -->