OCI Queue 概述
什么是 Oracle Cloud Infrastructure (OCI) Queue？
OCI Queue 具备高可用、高吞吐量特性，每秒能够摄取数百万条消息。用户可以发布、使用和删除 Queue 中的消息，也可以更新消息的可见性。
Queue 使用什么协议进行通信？
OCI Queue 支持 RESTful API、SDK 以及 STOMP。
什么时候可以使用严格保序（FIFO 队列）特性？
Queue 支持标准队列（尽力排序）。FIFO 队列（严格保序）是未来会推出的一项功能，目前还没有确切的时间。如果需要此特性，您可以提出支持请求或与 OCI 客户经理沟通。
OCI Queue是一项完全托管的、无服务器的消息传递服务，它具备高可用性、高吞吐量的特性，每秒能够摄取数百万条消息。以下是OCI Queue的一些主要特点和功能：
- 异步连接与服务分离：OCI Queue支持通过异步连接将服务分离，有助于独立扩展组件以及构建面向未来的设计。新组件可以透明地发布到或者订阅OCI Queue。
- 自动伸缩：OCI Queue可以自动按需添加资源并将工作负载分配给可用的使用者，有效应对意外的峰值流量。它可以在短时间内摄取任意数量的消息（管理峰值负载）并允许有限数量的使用者以较慢的速度处理消息。
- 可靠、公平的消息处理：OCI Queue可确保消息在被删除或过期之前一直存在，并确保消息至少传送给使用者应用一次。消息可以从队列中的随机通道使用，以提高处理公平性和防止“嘈杂”邻居。
- 消息处理特性：OCI Queue还支持多种消息处理特性，包括消息锁定（避免在使用者处理消息时或可见性超时结束之前发生重复读取）、消息批处理（分批发送、接收、更新或删除消息以优化成本）、传送尝试和死信队列（可以定义消息传送的尝试次数）等。
- 通信协议支持：OCI Queue支持RESTful API、SDK以及STOMP等多种通信协议，使得用户可以通过多种方式进行消息的发布、使用和删除等操作。
总之，OCI Queue是一种灵活、可靠、高性能的消息传递服务，适用于各种场景下的消息处理和事件驱动架构构建。
以下是一些关于OCI queue性能方面的特点：
- 高可用性：OCI queue服务通常设计为高可用性和容错性，以确保即使在出现故障时也能保持服务的连续性和可靠性。
- 高吞吐量：OCI queue支持高吞吐量的消息传递，能够处理大量的消息发送和接收请求。具体的吞吐量取决于您的使用模式、工作负载和配置。
- 低延迟：OCI queue旨在提供低延迟的消息传递，这意味着消息可以快速地发送到队列中，并且消费者可以快速地从队列中检索和处理消息。
- 可伸缩性：OCI queue服务能够自动扩展以满足工作负载的需求。随着消息传递量的增加，OCI queue可以动态地分配更多的资源来处理这些消息。
- 并发处理：OCI queue支持并发处理，允许多个消费者同时从队列中检索和处理消息。这有助于提高消息处理的效率。
- 持久性保证：OCI queue提供消息持久性保证，确保消息在发送后被安全地存储在队列中，直到被消费者成功处理。这有助于防止消息丢失和数据不一致性。
- 可定制性：OCI queue允许用户根据需要进行定制，包括设置队列的大小、消息的最大大小、消息的可见性超时等。这些设置可以根据应用程序的需求进行调整以优化性能。
- 监控和诊断：OCI queue提供了强大的监控和诊断功能，允许用户跟踪和诊断消息传递过程中的问题。这有助于快速识别和解决性能瓶颈或故障。
请注意，具体的性能表现可能会受到多种因素的影响，包括网络条件、工作负载特性、消息大小等。因此，在使用OCI queue时，建议进行性能测试和监控，以确保满足您的应用程序需求。
STOMP 介绍
STOMP（Streaming Text Orientated Message Protocol）是流文本定向消息协议，它是一种为MOM（Message Oriented Middleware，面向消息的中间件）设计的简单文本协议。它提供了一个可互操作的连接格式，允许STOMP客户端与任意STOMP消息代理（Broker）进行交互。
STOMP协议的特点包括简单性、灵活性和良好的扩展性。它使用简洁的命令和消息头来定义消息的传输方式，使得开发人员能够轻松地理解和实现该协议。同时，它可以在多种编程语言和消息代理之间进行互操作，这意味着开发人员可以选择他们喜欢的编程语言和消息代理来实现STOMP协议。此外，STOMP协议还允许开发人员定义和使用自定义的消息头和命令，以满足各种不同的需求。
STOMP协议通常用于在不同应用程序之间进行异步消息传递，支持发布/订阅和点对点两种消息传递方式。常见的STOMP消息代理服务器有Apache ActiveMQ和RabbitMQ等。
总的来说，STOMP协议是一种简单、灵活、具有良好扩展性的消息传递协议，广泛应用于各种异步消息传递场景。
STOMP 协议的特点包括：
- 简单性：STOMP 协议相对简单，易于理解和实现。
- 文本导向：协议使用文本格式进行消息传递，使得消息易于阅读和解析。
- 可互操作性：STOMP 协议具有良好的可互操作性，不同的客户端和消息代理可以通过 STOMP 进行通信。
- 异步传输：支持异步消息传输，适合处理实时性要求不高的场景。
STOMP 常用于以下场景：
- 实时消息通知：在需要实时向客户端发送消息通知的应用中，如聊天应用、新闻推送等。
- 数据采集与传输：将数据从客户端采集并发送到服务器进行处理或存储。
- 分布式系统：在分布式系统中，用于不同节点之间的消息传递和协调。
在使用 STOMP 时，需要注意消息大小限制、消息保留时间、错误处理等方面的问题。同时，根据具体需求，可以选择适合的 STOMP 客户端库和消息代理来实现消息的发送和接收。
OCI Queue 和 OCI Streaming 的区别
OCI Queue和OCI Stream在Oracle Cloud Infrastructure（OCI）环境中分别提供了不同的服务功能和特性，它们之间的主要区别如下：
OCI Queue：
- 定义：OCI Queue是一项完全托管的、无服务器的消息传递服务，旨在协助用户分解应用程序并构建非同步事件导向架构。
- 特性：
- 可伸缩性：OCI Queue能够自动按需添加资源，并将工作负载分配给可用的使用者，以应对意外的峰值流量。
- 高吞吐量：OCI Queue支持高吞吐量的消息传递，每个API每秒能够处理近乎无限数量的事务。
- 消息处理：OCI Queue确保消息至少传送给使用者一次，除非该消息被删除或过期。同时，它还支持消息锁定、消息批处理、传送尝试和死信队列等特性。
- 通信协议：OCI Queue支持RESTful API、SDK以及STOMP等多种通信协议。
OCI Streaming（Streaming Service）：
- 定义：OCI Streaming服务是一个面向开发人员和数据科学家的实时、无服务器、兼容Apache Kafka的事件流处理平台。
- 特性：
- 实时性：OCI Streaming服务提供实时的事件流处理，适用于需要即时响应的场景。
- Kafka兼容性：OCI Streaming服务兼容Apache Kafka，这意味着它提供了与Kafka类似的功能和API，使得用户能够轻松地将现有的Kafka应用程序迁移到OCI上。
- 集成性：OCI Streaming服务不仅与OCI、Database、GoldenGate和Integration Cloud等Oracle产品紧密集成，还为数百种各种类别的第三方产品提供开箱即用的集成功能。
- 供应商锁定效应降低：OCI Streaming服务的Kafka兼容性有助于降低供应商锁定效应，使得用户能够更灵活地采用混合云和多云架构。
总结来说，OCI Queue主要提供消息传递服务，适用于异步通信和事件驱动架构，而OCI Stream则是一个实时的事件流处理平台，兼容Apache Kafka，并提供了丰富的集成功能和灵活性。这两种服务在OCI环境中各有其独特的价值和应用场景。
OCI Queue和Steaming的场景选择
在选择OCI Queue和OCI Streaming时，需要根据您的具体需求和使用场景来决定。以下是两者的一些关键特性和使用场景，以帮助您做出决策：
OCI Queue：
- 定义：OCI Queue是一个完全托管的、无服务器的消息传递服务，可以自动扩展以满足工作负载需求。
- 特性：
- 可伸缩性：OCI Queue可根据需求自动添加资源，并将工作负载分配给可用的使用者，以应对意外的峰值流量。
- 高吞吐量：OCI Queue支持每个API每秒操作近乎无限数量的事务。
- 至少一次传送：确保消息至少传送给使用者一次，除非该消息被删除或过期。
- 消息锁定：将消息锁定，避免在使用者处理消息时或可见性超时结束之前发生重复读取。
- 消息批处理：分批发送、接收、更新或删除消息，以优化成本。
- 使用场景：OCI Queue适用于需要可靠、异步消息传递的场景，如事件驱动的应用程序、分布式系统、微服务架构等。
OCI Streaming：
- 定义：OCI Streaming是一个面向开发人员和数据科学家的实时、无服务器、兼容Apache Kafka的事件流处理平台。
- 特性：
- 实时性：OCI Streaming支持实时数据流处理，可用于处理实时生成的大量数据。
- 兼容性：OCI Streaming兼容Apache Kafka，允许开发人员使用熟悉的Kafka API和工具。
- 开放性：OCI Streaming提供了丰富的API和工具，支持与其他Oracle Cloud服务和第三方产品集成。
- 可扩展性：OCI Streaming是一个可扩展的平台，可以轻松地处理大量数据和多个数据流。
- 使用场景：OCI Streaming适用于需要实时处理和分析大量数据的场景，如大数据处理、实时数据分析、物联网应用等。
如何选择：
- 如果您需要可靠、异步的消息传递机制，并且关注消息的可靠传递和顺序，那么OCI Queue可能是更好的选择。
- 如果您需要实时处理和分析大量数据，并且希望使用Kafka生态系统中的工具和API，那么OCI Streaming可能更适合您的需求。
最终的选择应该基于您的具体需求、技术栈、集成需求以及成本效益等因素进行综合考虑。
参考链接
官方FAQ Queue： https://www.oracle.com/cn/cloud/queue/faq
官方FAQ Streaming： https://www.oracle.com/cn/cloud/streaming/faq
