个人中心
文章发布
退出
作者热门文章
- 在VisualStudio中部署GDAL库的C++版本（包括SQLite、PROJ等依赖）
- Android开机流程介绍
- STM32CubeMX教程31USB_DEVICE-HID外设_模拟键盘或鼠标
- 深入浅出Java多线程(五)：线程间通信
25
4
考虑到现有业务很多依赖于MQ的方式进行，这种方式需要依赖于MQ，发送消息到mq和消费mq消息时需要了解mq消息结构进行相应处理； 。
对于后续对同样的事件做其他处理的人如不能提前了解到已有相应消息发到了mq就得再发一次消息到mq等.
图1.1 消息中间件 。
现需要考虑在不依赖于Mq的形式下如何更优雅地实现异步任务处理！！！ 。
1.1 现有轮询方式 。
轮询：针对每一个业务记录一张轮询中间表，通过轮询扫描消费.
优点:
1. 时间性把控粒度高.
2. 每个业务彼此分离，互不干涉.
缺点:
1. 每次创建业务都要建立一张属于自己的轮询表，也要建立一个新的轮询配置.
2. 资源消耗大.
3. 研发效率低.
1.2优化方式 。
模拟RabbitMq的ACK方式建立一张共性表解决通用性业务的消息体存储,共性化业务通用一个轮询.
模拟RabbitMq的ACK模式，使用轮询的方式替代mq的消息发送机制。制定专属表字段Table_Name模拟RabbitMq的RoutingKey.
每个业务处理通过Table_Name方式实现接口进行派发处理。每个实现了轮询逻辑派发接口的类即可以认为是一个队列.
以这种方式可以有效的实现消息的异步处理.
优点:
1. 代码规范化，每个服务中心只需要建立集中的一个轮询业务； 。
2. 符合开闭原则，每增加一个轮询处理只要多实现一个接口类即可； 。
3.可以减少数据库资源的消耗； 。
4.减少无用代码的增加，提高开发效率.
缺点:
1.由于数据量的增加，轮询压力增大，对特殊业务的轮询时间性无法针对性的把控，需要建立特殊业务轮询处理（增加轮询）.
2.1演化方向：模型由图1.2 ——》 图1.3 。
图1.2 RabbitMQ 。
图1.3 定时任务模拟图 。
3.1什么是ack模式？
RabbitMQ 的 ACK 模式是指消息确认机制，即消费者消费消息后需要向 RabbitMQ 服务器发送一个 ACK（acknowledgement）信号来告诉服务器该消息已经被处理.
ACK 模式主要有以下两种:
1.自动确认模式（autoAck） 。
在自动确认模式下，消费者在收到消息后会立即向RabbitMQ 服务器发送一个 ACK 信号，表示该消息已经被消费.
这种模式适用于对于消息的可靠性要求不高的场景，比如日志处理等.
2.手动确认模式（manualAck） 。
手动确认模式下，消费者需要在处理完消息后，主动向RabbitMQ 服务器发送 ACK 信号.
如果消费者没有发送 ACK 信号，RabbitMQ 认为该消息没有被正确处理，并将该消息重新分发给其他消费者.
此外，在手动确认模式下，如果消费者在处理消息时出现异常，可以通过拒绝消息（NACK）来告诉 RabbitMQ 服务器该消息不能被处理， 。
此时 RabbitMQ 将会将该消息重新分发给其他消费者或保存到死信队列中.
4.1建立合适的表结构 。
1. Uid,table_name,msg,remark,ack 。
2. Hisid,Uid,table_name,msg,remark,ack （历史表，用于记录处理过的消息） 。
（表名称和字段名称可根据业务自行命名，以上数据结构供参考，可自行根据业务外拓字段） 。
1.规范化msg的输入形式。可以走切面或者监听的方式异步记录。写一个公用方法写入（特殊业务可调用该方法写入）.
2.规范化Table_Name字段：采用驼峰名称，代表哪个表写进来的数据.
3.规范化ack,默认设置为0；消费完成，写入2表（历史表）.
如有特殊要处理的，可以增加业务逻辑通过ack模式处理，这里ack默认值为0； 。
默认轮询处理失败一次ack自增1 。通用轮询方法只扫ack默认为0或者1的.
Ack不等于0，1的，通过二次轮询，第二个特殊轮询业务处理。（减少通用轮询的压力，避免造成轮询卡单。消息消费延缓等问题）.
如有特殊业务申请对应轮询：需要申请ack默认值处理。比如特殊业务1，ack值设置100。（0-9不建议，给默认通用轮询留下可用空间； 。
每次申请的特殊轮询ack默认在原先基础最大值上增加100，每次建立轮询通过这个方案执行的ack都要走申请，避免ack重复）.
方案一:
图1.4 类图 。
方案二:
图1.5 类图 。
以上类图开发自行根据习惯可自行选用哪种模式。 如有更好的方式请留言指教，以上供参考.
最后此篇关于共性化异步任务处理方案的文章就讲到这里了,如果你想了解更多关于共性化异步任务处理方案的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
25
4
0
我应该编写一个函数来打印一组给定的三个数字中两个较大数字的平方和。 我对这种情况的处理相当笨拙。我没有编写返回一组 3 中最大的两个数字的函数，而是编写了函数，以便表达式减少到两个所需的数字。 # S
如果有人可以提供帮助，我将不胜感激。我一直在敲我的头一天试图让这个工作。我已经在互联网上搜索并重新阅读了手册，但我就是不明白。 guile << __EOF__ ( define heading-li
目前我正在处理一个方案问题，其中我们正在使用方案列表表示一个图。我们使用的第一个变体是表示为 的边列表图 '((x y) (y z) (x z)) 我们正在使用的图的第二个变体被称为 x 图，表示为
我正在尝试创建一个函数，该函数将两个函数作为参数并执行它们。 我尝试使用 cond ，但它只执行 action1 . (define seq-action (lambda (action1 act
我提前为我的原始英语道歉；我会尽量避免语法错误等。 两周前，我决定更新我对 Scheme(及其启示)的知识，同时实现我在手上获得的一些数学 Material ，特别是我注册的自动机理论和计算类(cla
Scheme中有没有函数支持分数的“div”操作？ 意思是 - 11 格 2.75 = 4。 最佳答案 我认为你的问题的答案是:没有，但你可以定义它: #lang racket (define (di
我在scheme中实现合并排序，我必须通过定义两个辅助方法来实现:merge和split。 Merge 需要两个列表(已经按递增顺序)并将它们合并在一起。我这样做了如下: (define merge
尝试从终端加载方案文件。我创建了一个名为 test.scm 的文件，其中包含以下代码: (define (square x) (* x x)) (define (sum-of-squares x y)
我有以下代码: (define (howMany list) (if (null? list) 0 (+ 1 (howMany (cdr list))))) 如果我们执行以
我有点了解如何将基本函数(例如算术)转换为Scheme中的连续传递样式。 但如果函数涉及递归怎么办？例如， (define funname (lambda (arg0 arg1)
我正在尝试附加两个字符串列表 但我不知道如何在两个单词之间添加空格。 (define (string-concat lst1 lst2) (map string-append lst1
这个问题已经有答案了: How do I pass a list as a list of arguments in racket? (2 个回答) 已关闭 8 年前。 我有一个函数，它需要无限数量的
我对这段代码的工作方式感到困惑: (define m (list 1 2 3 '(5 8))) (let ((l (cdr m))) (set! l '(28 88))) ==>(1 2 3 (5 8
我正在为学校做一项计划作业，有一个问题涉及我们定义记录“类型”(作为列表实现)(代表音乐记录)。 我遇到的问题是我被要求创建一个过程来创建这些记录的列表，然后创建一个将记录添加到该列表的函数。这很简单
我有以下代码: (define (howMany list) (if (null? list) 0 (+ 1 (howMany (cdr list))))) 如果我们执行以
我正在尝试附加两个字符串列表 但我不知道如何在两个单词之间添加空格。 (define (string-concat lst1 lst2) (map string-append lst1
如何使用抽象列表函数(foldr、foldl、map 和 filter 编写函数)，无需递归，消耗数字列表 (list a1 a2 a3 ...) 并产生交替和 a1 - a2 + a3 ...？ 最
我试图找出在 Scheme 中发生的一些有趣的事情: (define last-pair (lambda (x) (if (null? (cdr x))
这个问题在这里已经有了答案: Count occurrence of element in a list in Scheme? (4 个答案) 关闭 8 年前。 我想实现一个函数来计算列表中元素出现
我正在尝试使用下面的代码获取方案中的导数。谁能告诉我哪里出错了？我已经尝试了一段时间了。 (define d3 (λ (e) (cond ((number? e) 0) ((e
我是一名优秀的程序员,十分优秀！