足球必发指数网可以借助关系数据库进行去重），推送实质席卷（淘宝贸易、商品、退款等消息），基于该推送供职，利用获取淘宝数据不需再连续轮询API，仅需正在收受到淘宝推送的音尘时挪用API获取即可，大大降低API挪用结果和消浸API利用用度。同时还供给音尘回流供职（
From淘宝：即淘宝向外推送淘宝（席卷天猫）的贸易、商品、退款等官方音尘。
那么怎样利用音尘供职呢？ 请看以下是音尘供职 From淘宝 和 To淘宝 两种方法的注意利用讲明。
音尘供职就像一个mq中央件, 对内承接生意音尘, 为接入的appkey划分队伍/分组, 把音尘存储下来。
必要挪用api消费音尘(低功能) 或 编码tmcClient长邻接消费音尘(高功能)。
① 播送音尘: 消费者下单等操作形成的播送音尘, 必要卖家用户授权appkey 且 appkey增加卖家用户到分组；
② 点对点音尘: appkey跟内部利用疏通好发送场景后, 内部利用自行向appkey发送音尘；
音尘属于用户(卖家), 需把用户增加到目的分组, 淘宝内部将音尘播送给通盘具有效户授权的appkey；
音尘属于appkey, 跟用户无合, 淘宝内部将定向发音尘给appkey；
相较于推形式，拉形式能有用避免流量顶峰期音尘消费不均、网卡聚集及重发率高的题目，对擢升利用供职质料有主动功用。
供给API收受音尘的方针是那种对众线程和长邻接收拾阻挠易的措辞利用的，譬喻PHP、Python，这些措辞官方短促没有供给SDK，能够通过下面两个API配合利用也能抵达收受和确认音尘的方针;
推选尽量用SDK方法，假若务必利用API，提议挪用taobao.tmc.messages.consume接口时尽量不要并发或并发量不要太大，可依据返回的音尘数目酌情增减拉取音尘的频次, 如拉取音尘量为空时, 守候1秒以上再轮询;
① 起首消费音尘：API名称：taobao.tmc.messages.consume音尘消费后，指针主动后移，下次挪用主动获取到未消费过的音尘，不过消费确认后的音尘无法再次获取。
② 然后确认音尘：API名称：taobao.tmc.messages.confirm获取音尘后，假若不确认，音尘供职会拔取机缘(约6分钟)重发，重发次数由音尘供职管造。
查看报警纪录。小心：生活发送报警限流情景（如，每10分钟仅收到一条报警邮件）。
MQ无法避免音尘反复（Exactly-Once），以是假若生意对消费反复绝顶敏锐，务须要正在生意层面举办去重收拾。能够借帮相干数据库举办去重。起首必要确定音尘的独一键，能够是msgId，也能够是音尘实质中的独一标识字段，比方订单Id等。正在消费之前判决独一键是否正在相干数据库中生活。假若不生活则插入，并消费，不然跳过。（实践进程要商讨原子性题目，判决是否生活能够实验插入，假若报主键冲突，则插入打击，直接跳过）
msgId肯定是全体独一标识符，不过实践利用中，或者会生活雷同的音尘有两个差别msgId的情景（消费者主动重发、因客户端重投契造导致的反复等），这种情景就必要使生意字段举办反复消费。
绝大个人音尘消费动作都属于 IO 蚁集型，即或者是操作数据库，或者挪用 RPC，这类消费动作的消费速率正在于后端数据库或者外体例的含糊量，通过补充消费并行度，能够降低总的消费含糊量，不过并行度补充到肯定水准，反而会降落。以是，利用必必要修设合理的并行度。 如下有几种篡改消费并行度的门径：
① 统一类tmcClient appkey group，通过补充或节减 tmcClient 实例数目来调动并行度。能够通过加呆板，或者正在已有呆板启动众个历程的方法。
② 降低或消浸单个 tmcClient 的消费并行线程，通过篡改参数 杀青。
爆发音尘聚集时，假若消费速率不断追不上发送速率，假若生意对数据央浼不高的话，能够拔取丢掉不首要的音尘。比方，当某个队伍的音尘数聚集到100000条以上，则实验丢掉个人或齐备音尘，如此就能够神速追上发送音尘的速率。示例代码如下：
依据tmcClient真实认qps本事来修设分组流控, 避免拉取过众音尘下来而又无法守时确认, 导致洪量音尘屡屡发送, 紧要影响功能和寻常生意。
音尘总量qps: 音尘形成量: 音尘源形成的音尘都存储正在 音尘供职的 mq队伍中；
确认量qps: tmcClient收到音尘后, 生意收拾实现, 主动上报确认；
寻常情景下, 确认量 = 推送量 = 音尘总量 且彼此相差不大意味着即时消费且确认；
* 单机流控值(低于32时,有毛刺,但均值寻常,第一秒为32,后续31秒为0)
① 音尘总量 推送量, 会有聚集, 受限于推送量亏折, 可按公式, 补充呆板数, 调动流控值；
② 推送量 确认量, 会有重发, 受限于确认量亏折, 可按公式, 消浸推送量(消浸呆板数,调动流控值), 或可擢升tmcClient确认本事；
③ 推送量 音尘量, 讲明有聚集, 正在分外把聚集中的音尘推送到tmcClient, 若确认量跟不上, 按②收拾。
③ 慢慢增加单机流控值 为 32,64,128..., 每批次10分钟, 伺探单机确认量qps, 若确认量qps推送量qps,则 回调单机流控值为前次的值；
④ 眼前单机流控值则为单机确认qps极限, 弗成再调大, 可调优后反复设施③；
⑤ 若眼前确认qps量小于音尘形成量qps, 则按需补充tmcClient呆板数, 或守候渐渐消费削峰填谷。
确保订阅篡改时辰, 授权逾期时辰, 和预期形成音尘的场景时辰成婚(时序), (点对点音尘需指定生意场景形成音尘)
若以上排查不出结果能够提交题目到扶帮中央附上：AppKey、(用户nick)、音尘形成原因生意场景、音尘形态、音尘约略时辰、订单的tid、商品的num_iid。
1）appkey不断不消费, 聚集过众(万级)或过久(半小时以上)会, 消费流控值预期会*30%；
3）appkey消费了不确认, 确认比过低(20%), 会自适当局限消费速度, 持久如斯, 会酌情加白禁止消费音尘；
4）音尘最众保存8至24小时(差别集群有分别), 无论发没发, 有没有重发, 紧迫情景下会进一步节减保存时辰, 请即时消费并寻常确认音尘；
支拨形态 只要有限的付款合连形态罗列值 [ 守候付款(未付款), 守候卖家发货(已付款), 贸易告成(确认收货), 贸易合上(退款实现) ], 没有已发货的形态；
音尘分组是用户音尘远隔的一种方法，组内用户的音尘只会发送到雷同组名的邻接上。统一个组扶帮众个邻接，统一组的音尘，随机发送到组内的某一个邻接。假若要用户的类型对音尘区别应付，譬喻优先保障付用度户，然后再保障免用度户，就能够通过音尘分组来收受差别用户的音尘。每个利用最众创修50个分组，每个分组用户数不限。
众邻接收音尘是指统一分组内ISV供职器与TOP的音尘供职器修设众个邻接来互帮消费音尘。众链接是对统一个分组而言，音尘鄙人发时随机拔取从分组内的众个邻接中拔取一个邻接下发音尘。通常一台呆板安放一个tmcClient, 可调动收拾音尘的线程数, 众安放几台呆板举办互帮消费负载；
10）确认音尘无效, 确认后还屡屡重发音尘: 常睹于http api确认时, 确认音尘outgoingId long型精度遗失, 导致无法寻常确认；
利用未订阅(开通)音尘供职，就利用TmcClient来收受音尘, 请于音尘管造台订阅纵情音尘。
必要isv先跟内部对接的二方疏通，让对接的二方正在怒放平台内部去申请创修 isv - taobao 流向的音尘topic
