范文健康探索娱乐情感热点
投稿投诉
热点动态
科技财经
情感日志
励志美文
娱乐时尚
游戏搞笑
探索旅游
历史星座
健康养生
美丽育儿
范文作文
教案论文
国学影视

MQ标准

  目录
  MQ标准 1
  1 Openmessaging 介绍 1
  2 openmessaging内容介绍 2
  消息模型 3
  openmessaging使用样例 4MQ标准1 Openmessaging 介绍
  Openmessaging 云原生,与厂商中立,分布式消息开放标准。
  消息在数据处理,限制架构中被使用,例如( for decoupling)队列,缓存,有序,副本化等,当数据在不同消息和流平台传输时,出现了复杂的问题,意味着更多的工作内容。虽然JMS在过去一段时间是一个好方案,在java环境中有一定的缺陷,在负载均衡,熔断处理,权限处理,安全和流处理缺少明确的标准,使得不满足现在云原生的消息流应用。
  openmessaging标准在于:语言不限,平台独立,消息支持多平台,架构和系统全面的,云原生,厂商中立,工业级分布式消息便于(Facilitating )使用基准测试来测试应用性能云数据消息流更加灵活,独立,安全,规模化(scalability)打造贡献者成长生态圈
  标准不包含:指定语言运行api性能评估基准测试接口和其他系统数据交换连接接口2 openmessaging内容介绍
  对象
  Namespace 独立命名空间,资源隔离;
  Topic 表明和消息投递方向,保存和持有消息;
  Producer 发送消息到topic;
  Consumer 消费topic中收到的消息;
  Routing topic消息是服务侧的,不是消费侧的,routing负责通过pipeline将消息从topic移动到queue;
  Queue 封装了消息目的地的管理对象,queue被分成了分区,分区使用特定方法;
  Delivery semantics 描述了投递机制,在producer和consumer之间存在三个机制保证:至少一次:至少被消费一次最多一次:最多被消费一次,消息可能丢失只是一次:被消费一次,仅仅一次
  topic和queue有哪些区别?topic和queue都是用来承载messagetopic面向的是生产者,queue面向的是消费者topic里消息来自生产者,queue里消息来自topic或直接来自生产者queue被分成了分区,topic没有这样的定义大多数情况下queue是topic数据小子集合创建和销毁queue和生产者无关,很easy
  数据类型,在属性中,这些抽象数据类型可以使用
  String:可以打印的unicode字符串
  Binary:字节序列
  Keyvalue: 字典类型。键类型为string,值类型为string,binary,numeric
  Numeric: short : 15次方的范围
  Integer:31次方的范围
  Long 63次方的范围
  Float 32比特浮点数据
  Double 64比特浮点数据
  Object :string,binary,keyvalue,numeric的泛型
  URI:string表示uri-reference,遵守 RFC 3985消息模型消息类型-字节型
  消息体包含了连续的流字节,消息体会迭代匹配存在的消息类型格式。自定义消息类型去编码消息体,厂商负责在规则下解码这些字节数据。消息格式
  包含:版本,凭证,系统头,扩展头和消息体Version :string,消息标准版本,需要填写Header:keyvalue,所有消息支持同样的头区域集合,这些区域集合用来验证身份和投递消息,需要填写extensionHeader:扩展头,keyvalue,消息中间件扩展元数据。不是必要的,将来大多数消息中间件会实现相关内容,这些区域很多开发消息流的人都广泛了解Properties:keyvalue,除了消息头,用户可以通过这些区域去传递一些属性Data:字节,传输的数据部分,包含应用的数据,完全对服务端透明,无法查看和修改消息体,可选填写
  具体每一部分包含内容描述如下
  Message Header
  消息头
  Messageid:string,唯一标识,系统生成值,必填,非空字符串
  bornTimestamp:long,客户端发送时间,不是传输时间,传输时间可能延迟,系统自动生成,必填
  Bornhost:string,记录消息发送端的本地host,必填非空
  Qos:integer,记录消息的投递方式,有三种0,1,2,上文已经提到过三种投递方式
  Compression:string,消息体压缩算法,厂商保证接收正常,可选
  Destination:string,描述了消息投递逻辑位置,如queue和topic,指定destination后,会送到特定目的地,消息收到后,这个值标识所在queue的逻辑位置。
  消息模型案例
  {
  "message" :{
  "version" : "1.0.0" ,
  "header" :{
  "messageId" : "7F00000100002873000000000004F49C" ,
  "destination" : "orderQueue" ,
  "bornTimestamp" : 1533780827824 ,
  "bornHost" : "172.24.0.101:10035" ,
  "compression" : "gzip" ,
  "qos" : 1
  },
  "extensionHeader" :{
  "partition" : 1 ,
  "storeTimestamp" : 1533780827825 ,
  "storeHost" : "172.24.0.102:52511" ,
  "messageKey" : "orderId-103368921567" ,
  "correlationId" : "7F00000100002873000000000004F2B4" ,
  "delayTime" : 30000 ,
  "transactionId" : "1E0578887D3F18B4AAC22B64D2B40A62" ,
  "expireTime" : 1533780830000 ,
  "traceId" : "1E0578887D3F18B4AAC22B64D2B00A5E" ,
  "priority" : 1
  },
  "properties" :{
  "service" : "helloService"
  },
  "data" :{
  }
  }
  } openmessaging使用样例P2PPublish/SubscribeBroadcastHighwayStreamingFilterRoutingRPCP2P
  点对点发送,最简单,从生产者到消费者,队列只有一个分区Publish/subscribe
  发布,订阅,发送消息到队列有多个分区,分区算法是round-robin 或hash方式,这些分区按照特定方式指派给了订阅这个queue的消费者Broadcast
  广播下发送到queue消息会被所有消费者消费。Highway
  高速路下,关注消息速度,生产者发送大量不重要的消息到queue,实现的方式是批量处理Streaming
  streamingConsumer在这种场景使用,集成streaming和bigdata平台。支持指定queue多个分区消息的处理。Filter
  过滤方式,消费者关注特定消息,可以通过filter进行过滤,再放入queue中Replication
  复制冗余转发方式,在不同平台上,多区域复制,然后其他区域也可消费消息。RPC
  Rpc等同于同步消息,不是传统c2s模式,是c2s2c模式

格登山记功碑风云在昭苏县西南面苏木拜河东岸的格登山上,可以望见山之西面,那一片田畴农庄公路流水口是,只能望,不能去,因为那已属于另一块国土。就在这座山上,一座记载历史风云的石碑,巍然矗立。它就是著现代艺术来到传统村庄!人民日报关注腾冲市五合乡帕连村1月17日人民日报12版刊文关注云南省保山市腾冲市五合乡帕连村随着艺术的注入让这个传统村落变身诗意村庄为乡村带来了人气与活力全文如下核心阅读一入夜,创意诗句灯饰点亮村庄美术馆内,当超万辆汽车排队出口!新年运车忙,江苏太仓港整车出口夜间不打烊视频加载中(央视财经经济信息联播)江苏太仓港是长江上最大的集装箱港口。从2022年开始,港口的整车出口量增长迅速。进入2023年,这一势头继续保持,预计今年出口量比去年将实现翻倍。贝壳研究院已有两城下调首套房贷利率至3。8未来或有更多城市下调利率根据贝壳研究院统计数据显示,1月首套主流利率平均为4。10,环比上行1个基点,二套平均为4。91,环比持平,同比分别回落146个基点和93个基点。1月银行放款周期31天,受近期疫情遇见你丨七旬修鞋匠十四年资助百余名贫困生江苏省淮安市的王建荣,是一名修鞋匠,今年77岁的王大爷,3岁时患病导致下肢残疾。为了养活自己,他自学修鞋手艺,自食其力。尽管收入微薄,但王建荣老人14年来陆陆续续将修鞋攒下来的积蓄婚内住房公积金属夫妻共同财产原标题夫妻离婚诉求分割住房公积金越来越多海南两起案例判决表明(引题)婚内住房公积金属夫妻共同财产(主题)法治时报记者王天宇恋人相爱步入婚姻殿堂后,很多家庭在经济开支上不分你我,我挣孕期贫血,对孕妈自身和胎儿都有哪些危害呢?该如何解决呢?在孕期,比较常见的一种并发症是贫血,其中以缺铁性贫血尤为多见,约占95。缺铁性贫血,指的是由于各种因素导致的体内铁储存量下降,影响红细胞的生成而引起的一种贫血。该病会导致不良妊娠的萌娃出动!攀树飞盘独轮车罗湖这场户外活动太赞了太可爱了吧!前方萌娃出没忍不住想rua这是哪里?!欢迎来到活泼身心,启发智慧罗湖全民公益活动日活动的现场近日,由罗湖区文化广电旅游体育局主办,深圳市罗湖中财投资发展公司深圳市罗湖区下一站,金坛茅山!我在这里等你回家过年!随着春节的临近,紧张的工作和忙碌的节奏,都被心底涌动的思念所占据,今年你是否回到久别的家乡?看过世界的人,最想回家。在城市的工作生活中,逐渐迷失的我们,无论是为了疗伤还是净化,都迫水晶虾游戏新春创作纪夏日周末,我带着老婆孩子去锦溪古镇游玩。不巧的是,刚到锦溪便下起了暴雨。撑伞下车后,眼前的锦溪古镇内溪水穿流,一派泽国景象,雨天更显江南水乡人家之秀美。陈妃水冢古莲池三亚又一次火爆全网,让人惊叹,为什么大家春节都爱去三亚旅游?每年冬天,一波又一波的人从自己的城市奔向三亚,如同候鸟在天气寒冷时从北方飞往南方。全国所有大大小小的城市中,这座海岛城市在天气寒冷时总是格外受偏爱,成为人们温暖过冬的首选地。位于海
浙江十大旅游景点,去过5个你就是浙江人如果只给你一次机会,让你选择一个省份去旅游,你第一个想到去哪里呢,不用纠结,就来橙子的故乡浙江吧!浙江,是中华人民共和国省级行政区。省会杭州,位于长江三角洲地区,中国东南沿海,东临世界杯,有支中国队2022年卡塔尔世界杯已经进行了8场比赛,除了球员们精彩激烈的较量,中国护旗手裁判也已纷纷亮相赛场。揭幕战入场仪式上,三位中国小球员以国际足联旗帜护旗手的身份入场,来自中国的裁判马本届世界杯爆冷的突尼斯昨天晚上2022卡塔尔世界杯D组丹麦队对阵突尼斯队的比赛,双方90分钟激战均未能得分,最终00握手言和,双方各取1分这是2022世界杯首场没进球得分的比赛。实力强劲的丹麦队被外界视死亡之组激战!日本恐难复刻韩国给德国添堵?德国小组赛首轮面对日本北京时间11月23日晚间21点整,2022卡塔尔世界杯E组将迎来一场焦点战,德国坐镇哈里发国际体育场直击亚洲劲旅日本,由于德国在上届世界杯曾小组收官战被韩国2深度解读NBA五年5支不同队夺冠或重现,上次还要回到1979年北京时间11月23日,NBA常规赛继续进行,近日知名记者BenRohrbach撰文,对目前NBA整体发展趋势进行了分析,并表示现在NBA已经进入群雄并起的时代,每个球员和球队都有机莱万不被进球是优先事项我们需要更多球员制造威胁卡塔尔世界杯C组小组赛第一轮,墨西哥00与波兰互交白卷。赛后,罚失点球的波兰球星莱万多夫斯基在接受采访时,谈到了球队的表现。我认为这是一场势均力敌的比赛,两支队伍都有机会赢。我们需硬!T哈里斯我的脚踝是受伤了但我不会让球队缺四首发去比赛直播吧11月23日讯今日NBA常规赛,76人主场115106击败篮网。今日带伤上阵的托拜亚斯哈里斯赛后接受了采访。76人常规主力恩比德哈登和马克西今日均因伤无法出战。谈到今日自己在奥胖谈霍华德制霸中国台湾联赛面对1米73球员防守没啥值得骄傲北京时间11月23日,NBA名宿,前湖人队中锋奥尼尔最近在做客节目时聊起了霍华德在中国台湾联赛的超级表现,奥胖对霍华德个人秀不以为然,认为他是降维打击,没什么值得骄傲的。这没什么值卡塔尔世界杯上出现了多次超长补时卡塔尔世界杯前三场比赛时长卡塔尔vs厄瓜多尔10018英格兰vs伊朗11716塞内加尔vs荷兰1024911月21日,国际足联裁判委员会主席科里纳有对这种情况做了解释的。在昨天晚上42!世界杯4强队亮相,英法荷狂轰12球,只有阿根廷阵亡从落后到反超,法国队世界杯首战41逆转澳大利亚,姆巴佩一射一传,吉鲁梅开二度,拉比奥破门,卫冕冠军打破魔咒,首战开门红,全队士气提升,主教练德尚算是松了口气,这次他们应该不会受到小世界杯夺冠会退役吗?莫德里奇如果能做到我会说再见直播吧11月23日讯北京时间11月23日1800,本届世界杯小组赛F组第1轮,克罗地亚将对阵摩洛哥。赛前,克罗地亚队长莫德里奇表示,希望大家全力以赴,争取获得成功。关于与2018年