EventQueue的配置方法介绍
· queueRedis: 配置Redis队列实例,我们使用jedis客户端。
· processingErrorRetryCount :本地任务队列中失败后的重试次数,当Disruptor处理失败时会进行重试。
· queueName :我们使用的Redis等待队列名称,任务会从该队列拉取,队列使用List数据结构实现。
· maxBakSize :队列的镜像大小,当从等待队列中拉取任务时,会放入一份镜像/备份队列,从而当业务处理出现问题时进行重放,业务实现时要考虑幂等性。
接下来是EventHandler配置。
最后是EventWorker实现。
业务组件EventWorker:用于创建Disruptor相关组件,包含如下配置项目。
· init/stop :init用于初始化并启动Disruptor。Stop用于当JVM终止时停止Disruptor组件。
· ringBufferSize :环形队列大小,大小必须是2的倍数。
· eventHandlerMap :映射EventQueue与EventHandler的关系,从特定的EventQueue中获取的任务将被关联的EventHandler处理。
本文地址:EventQueue的配置方法介绍 _http://longshunzhuangshi.com/wangzhanseo/40.html 本文tag标签:EventQueue的配置方法介绍
上一篇:网站seo关键词选择中的常见错误