//rest风格写_REST /使用提要发布事件

//rest风格写

处理事件

当使用多个解耦的服务时(例如,在微服务体系结构中 ),很有可能需要一种方法来将某种域事件从一个服务发布到一个或多个其他服务。

许多广泛采用的解决方案依赖于单独的基础结构来解决此问题(例如事件总线或消息队列)。

活动提要

解决此问题的另一种方法是使用提要 。 RSS或ATOM之类的提要通常用于订阅网页。 每当有新文章发布到订阅的网页时,提要阅读器应用程序(例如,浏览器插件或移动应用程序)都可以将新文章通知用户。 提要阅读器通常会定期轮询提供的提要端点,以查看是否有新文章。

可以使用提要将事件发布到其他服务,而不是将新文章发布到RSS阅读器。 除了用于存储事件(您可能已经拥有)的标准数据库之外,这不需要任何其他基础结构。

RSS和ATOM都是XML格式,因此如果我们要提供JSON API,则不合适。 还有JSON Feed ,类似于RSS和ATOM,但使用JSON。 像RSS和ATOM一样,JSON Feed专注于网站内容,因此,许多(可选)提要和提要项属性对于发布域事件(例如faviconcontent_htmlimagebanner附件 )不是很有用。 但是,JSON Feed具有简单的扩展机制,可让我们在Feed中定义自定义字段。 这些字段必须以下划线开头。 如果JSON Feed不能满足您的需求,您还可以提出自己的feed格式,这应该不难。

具有两个已发布域事件的示例JSON Feed可能如下所示:

 { "version" : " https://jsonfeed.org/version/1 " , "title" : "user service events" , "feed_url" : " http://userservice.myapi.com/events " , "next_url" : " http://userservice.myapi.com/events?offset=2 " , "items" : [ { "id" : "42" , "url" : " http://userservice.myapi.com/user/123 " , "date_published" : "2020-05-01T14:00:00-07:00" , "_type" : "NameChanged" , "_data" : { "oldName" : "John Foo" , "newName" : "John Bar" } }, { "id" : "43" , "url" : " http://userservice.myapi.com/user/789 " , "date_published" : "2020-05-02T17:00:00-03:00" , "_type" : "UserDeleted" , "_data" : { "name" : "Anna Smith" , "email" : "anna@smith.com" } } ]  } 

第一个事件(ID为42 )指示用户资源/ user / 123的名称已更改。 在_data块中,我们提供了一些可能对订户有用的附加事件信息。 第二个事件表明资源/ user / 789已被删除, _data块包含已删除的用户数据。 _type_data没有以JSON Feed格式定义,因此以下划线(JSON Feed扩展格式)开头。

提要属性next_url可用于提供某种分页。 它告诉客户端在当前提要中的所有事件都已处理后,在哪里可以查找更多事件。 我们的Feed仅包含两个事件,因此我们告诉客户端使用偏移量参数2调用Feed端点以获取下一个事件。

一般注意事项

如果您使用JSON Feed或使用自己的feed格式,则在构建供发布事件的feed时应考虑以下一些常规事项:

提要项是不可变的

提要项表示域事件,它们是不可变的。 必要时,客户可以使用唯一的Feed项目ID来检查他们是否已经处理过Feed项目。

Feed项目订单未修改

提要中项目的顺序不变。 较新的项目会附加到Feed的末尾。

客户应该只能请求到目前为止尚未处理的提要项。

为避免客户需要一遍又一遍地处理所有提要项以查看是否有新项(例如,通过检查date_published项属性),提要应提供一种仅返回新项的方法。 使用JSON Feed时,可以通过next_url属性完成。

下图试图显示可能的next_url行为:

在第一个Feed请求中,只有两个事件可用。 两者均由服务器以及包含偏移量参数2的next_url一起返回。客户端处理了两个提要项目之后,它使用偏移量2请求下一个项目。没有新项目可用,因此没有内容的空提要服务器返回一个新的next_url 。 客户端会记住先前的next_url,并在稍后再重试该请求。 这次返回的是新项目,其更新的next_url包含偏移量 3。

当然,您可以想出不同的方法来达到相同的结果。

和性能?

显然,从性能的角度来看,提要不能与任何高吞吐量的消息传递解决方案竞争。 但是,我认为对于许多用例来说就足够了。 如果它降低了系统的复杂性,那可能是一个值得权衡的问题。

要考虑的事情是:

  • 服务器创建的事件数
  • 订阅者人数
  • 与事件关联的数据量
  • 事件发布和处理之间的可接受延迟。 这定义了订户的轮询间隔

由于域事件具有不变性,因此在服务器上可以选择使用事件缓存来减少数据库查找。 长轮询和条件GET请求是减少网络负载的可能选项。

结论

提要提供了一种使用REST API将事件发布到其他系统的替代方法,除了用于存储事件的数据库外,无需其他基础结构。 您可以使用现有的Feed格式(例如JSON Feed),也可以使用自己的自定义Feed格式。

由于提要的轮询性质,如果您有大量事件和很多消费者,则此解决方案可能不是最佳选择。

翻译自: https://www.javacodegeeks.com/2020/05/rest-using-feeds-to-publish-events.html

//rest风格写

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/331390.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Java IO总结

一、IO的类型 面向字节的流,面向字符的流二、面向字节的流 (1)InputStream FileInputStream FilterInputStream -BufferedInputStream -DataInputStream -PushbackInputStream 回退流 unread() ObjectInputStream PipedInputSt…

java安全——加密

【0】README1)本文文字描述转自 core java volume 2,旨在学习 java安全——加密 的基础知识;2)java 安全性的第二个重要方面是加密。3)认证对于代码签名已足够了-没必要将代码隐藏起来。但是,当applet或者应…

java 异常 最佳实践_处理Java异常的10种最佳实践

java 异常 最佳实践在本文中,我们将看到处理Java异常的最佳实践。 用Java处理异常不是一件容易的事,因为新手很难理解,甚至专业的开发人员也可能浪费时间讨论应该抛出或处理哪些Java异常。 因此,最大的开发公司对如何使用它们有一…

Java NIO总结

一、NIO NIO是new IO,也是非阻塞IO。有Channel、Selector、Buffer、Pipe、FileLock等类。 Buffer在java.nio包 Channel、Selector、Pipe、FileLock等在java.nio.channels包 二、Channel通道 设置非阻塞configureBlocking(false); 注册选择器register(selector,…

java 不可变map_如何用Java创建不可变的Map

java 不可变map你好朋友, 在本教程中,我们将看到如何在Java中创建不可变的Map。 –不可变的类或对象是什么意思? –什么是不可变地图? –如何在Java中创建不可变的Map? 不变的类或对象是什么意思? 不可…

ToolProvider.getSystemJavaCompiler() return null 的解决方法

【1】利用java 编译器API 编译 普通的java文件 1.1)代码如下: package com.corejava.chapter10_2;import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.OutputStream;import javax.tools.JavaCompiler; import jav…

脚本错误和安全警报怎么解决_适用于应用程序错误的AWS警报

脚本错误和安全警报怎么解决监视对于任何实际应用都是关键的。 您必须知道正在发生的事情,并在发生问题时实时得到警报。 AWS为此提供了CloudWatch,并自动为您提供了许多指标。 但是,您必须定义一些自己的东西。 然后,您需要定义适…

java平台脚本+java编译器API

【0】README 0.1)本文文字描述转自 core java volume 2, 旨在学习 java平台脚本java编译器API 的 基础知识; ------------------------------------------------------------------------------ 【1】java平台的脚本 1)脚本语…

Java 多线程总结

一、多线程实现方式 (1)继承Thread类,覆盖run方法 (2)实现Runnable接口,覆盖run方法,将对象传人Thread对象中实现Runnable接口比继承Thread类所具有的优势: 1)适合多个相…

古巴比伦乘法_古巴:为生产做准备

古巴比伦乘法“它可以在我的本地机器上运行!” 如今,它听起来像模因,但是“开发环境与生产环境”的问题仍然存在。 作为开发人员,您应始终牢记,您的应用程序有一天将在生产环境中开始运行。 在本文中,我们将…

java编译器API——使用编译工具

【0】README 0.1)以下内容转自: http://suntips.iteye.com/blog/69002 0.2)for basic java compiler API, please visit http://blog.csdn.net/pacosonswjtu/article/details/50718494 1)当你需要更好的处理这些结果时,你可以使…

Java 线程同步总结

一、synchronized(1)synchronized方法 (2)synchronized块 二、Lock 注意:及时释放Lock锁,否则会出现死锁,通常在finally代码释放锁 (1)ReentrantLock 实现…

aws es方案_AWS Elasticsearch后模式

aws es方案碰巧我们在SaaS版本的LogSentinel上遇到了生产问题–我们的Elasticsearch停止了对新数据编制索引。 由于Elasticsearch只是辅助存储,因此没有数据丢失,但这给我们的客户带来了一些问题(他们无法在其仪表板上看到实时数据&#xff0…

java注解总结

【0】README 0.1)本文主要对 java 注解做总结; 【1】处理注解的级别 level1) 在运行期级别处理注解: http://blog.csdn.net/pacosonswjtu/article/details/50719361level2)在源码级别处理注解: http://b…

Java 类加载总结

一、类加载过程 装载链接验证准备解析初始化二、类初始化情况 1)创建类的实例,也就是new一个对象 2)访问某个类或接口的静态变量,或者对该静态变量赋值 3)调用类的静态方法 4)反射(Class.…

maven依赖管理_依赖管理和Maven

maven依赖管理Maven伟大而成熟。 几乎所有事物都总有解决方案。 您可能在组织项目上遇到的主要情况是依赖管理。 而不是每个项目都具有自己的依赖关系,您需要一种集中的方式来继承那些依赖关系。 在这种情况下,您可以在父舞会上声明托管依赖项。 在我的…

JavaBean 持久化

【0】README 0.1)本文文字描述转自 core java volume 2,旨在学习 JavaBean 持久化 的基础知识; 0.2)本文所有源代码荔枝均为原创; 0.3) for complete souce code, please visit https://github.com/pa…

apache kafka_Apache Kafka消费者再平衡

apache kafka消费者重新平衡决定哪个消费者负责某个主题的所有可用分区的哪个子集。 例如,您可能有一个包含20个分区和10个使用者的主题。 在重新平衡结束时,您可能希望每个使用者都从2个分区中读取数据。 如果关闭了这些使用者中的10个,则可…

Java 注解总结

一、注解定义 注解早在J2SE1.5就被引入到Java中,主要提供一种机制,这种机制允许程序员在编写代码的同时可以直接编写元数据。 二、元注解 Target 说明了被修饰的注解的应用范围,也就是被修饰的注解可以用来注解哪些程序元…

编译原理三大经典书籍(龙书 虎书 鲸书)

以下内容转自: http://blog.csdn.net/skymingst/article/details/7436892 1、龙书(Dragon book) 英文名:Compilers: Principles,Techniques,and Tools 作者:Alfred V.Aho,Ravi Sethi,Jeffrey D.Ullman 中文名&…