云服务器价格_云数据库_云主机【优惠】最新活动-搜集站云资讯

阿里云_兴化网站建设_年度促销

小七 141 0

这个博客描述了使用新的AMQP适配器配置异步消息处理的选项,客户可以使用AMQP(高级消息队列协议)协议连接到消息传递系统。它描述了配置、先决条件和限制。AMQP适配器适用于2019年12月8日发布的SAP Cloud Integration客户。

在许多集成场景中,必须通过消息传递系统在应用程序或系统之间交换消息或事件。有了新的AMQP适配器,sapcloudintegration可以用作此类消息或事件的提供者或使用者。云集成可以使用AMQP(Advanced Message Queuing Protocol,微信返利机器人,高级消息队列协议)协议版本1.0连接到消息传递系统,并使用AMQP发送方适配器消费消息或事件,或者使用AMQP接收方适配器将消息或事件存储在Message broker中。按照下面描述的步骤写入或使用message broker中的队列和/或主题。

前提条件:消息系统设置

要能够连接到message broker中的队列或主题,必须在message broker中创建队列和/或主题。这需要使用消息系统提供的配置工具在消息系统上完成。

在某些消息系统中,您需要配置锁定持续时间,以确保消息不会被多次使用。此超时必须长于消息的预期处理时间,否则将导致消息重复。

请注意,只能使用消息系统提供程序提供的工具来执行对队列、主题和队列或主题中消息的监视。这些监视器没有集成到云集成中。在SAP Cloud Platform Integration中,您可以使用AMQP适配器监视集成流以及发送到消息传递系统或从消息传递系统中使用的消息。您可以在本博客的"监控"部分找到有关这些选项的更多详细信息。

AMQP接收器适配器

AMQP接收器适配器可用于将消息从云集成发送到外部消息系统中的队列或主题。下面的图片显示了一个带有HTTP发送方适配器和AMQP接收方适配器的小示例场景。HTTP发送方适配器接收消息,物联网工程,定义一些头并在groovy脚本中进行转换,然后通过AMQP适配器将消息发送到消息传递系统:

在AMQP接收方通道中,必须进行以下配置才能连接到消息传递系统。请注意,这些设置非常特定于连接的消息传递系统,下面的消息传递系统特定章节中列出了一些示例设置。

协议:传输协议:选择消息传递系统支持的协议。传输控制协议WebSocket

连接:主机:指定消息传递系统的主机名。端口:指定消息传递系统的端口。代理类型:如果要通过云连接器(内部部署)或直接通过Internet进行连接,请选择此配置选项,适配器的1.1版(2020年1月更新版)提供此配置选项。有关更多详细信息,请参阅博客How to connect to an on premise AMQP server via Cloud Connector。路径:对于WebSocket,网站建站平台,指定消息传递系统的访问路径。Connect with TLS:选择是否必须使用TLS进行连接。身份验证:选择消息传递系统支持的身份验证方法。SASL(简单身份验证和安全层)OAuth2客户端凭据没有凭证名称:选择已部署凭证的别名。

处理:目标类型:指定是否将消息发送到消息系统中的队列或主题。主题排队目标名称:指定队列或主题的名称。可以使用标头动态定义此值:${标题.队列ABC}或财产:${属性.队列ABC}.过期期限:指定消息的TTL(生存时间)。如果未指定任何内容,则应用消息传递系统中队列或主题订阅的设置。消息传递系统如何解释定义的TTL取决于消息传递系统。传递:指定消息传递系统是否必须确保消息不会丢失,即使在意外终止的情况下也是如此。持久的非持久性

AMQP Sender Adapter

AMQP Sender Adapter可用于在云集成中使用来自外部消息系统中的队列或主题订阅的消息。下图显示了一个带有AMQP发送方适配器和SOAP接收方适配器的小示例场景。消息由消息传递系统的AMQP发送方适配器使用,在groovy脚本中执行一些转换,然后通过SOAP适配器将消息发送到接收方:

在AMQP发送方通道中,需要完成以下配置,在消息传递系统特定章节中的示例设置:

协议:传输协议:选择消息传递系统支持的协议。传输控制协议WebSocket

连接:主机:指定消息传递系统的主机名。端口:指定消息传递系统的端口。代理类型:如果要通过云连接器(内部部署)或直接通过Internet进行连接,请选择此配置选项,适配器的1.1版(2020年1月更新版)提供此配置选项。有关更多详细信息,请参阅博客How to connect to an on premise AMQP server via Cloud Connector。路径:对于WebSocket,指定消息传递系统的访问路径。Connect with TLS:选择是否必须使用TLS进行连接。身份验证:选择消息传递系统支持的身份验证方法。SASL(简单身份验证和安全层)OAuth2客户端凭据没有凭证名称:选择已部署凭证的别名。