手机站:/m

域名交易_服务淘客小程序-器报500_好用

时间:2021-09-08 14:04编辑:淘客樊里来源:淘客樊里当前位置:主页 > 服务器 >

嗨,云平台集成商!

在这篇博文中,我们将了解如何通过AMQP将信息从CPI发送到企业消息服务。一旦消息到达队列中,它将在节点.js在Cloud Foundry上运行的应用程序。

这是一个博客系列,在单独的博客文章中包含以下主题:

为了不重新发明轮子,并赞扬社区成员的早期博客文章,我想指出以下博客文章:

云集成-使用AMQP适配器连接到消息系统

https://blogs.sap.com/2019/11/20/cloud-integration-connecting-to-external-messaging-systems-using-the-amqp-adapter/

云集成-如何通过云连接到本地AMQP服务器连接器

https://blogs.sap.com/2020/01/17/cloud-integration-how-to-connect-to-an-on-premise-amqp-server-via-cloud-connector/

SAP CPI–AMQP渠道与云事件代理–SOLACE

https://blogs.sap.com/2020/02/08/sap-cpi-amqp-channel-with-cloud-messaging-solace/

这是因为这些博客帮助我开始了AMQP云平台集成中的消息传递渠道。它们非常详细,解释得很好,值得一看。

在这篇博文中,我们将继续研究先前博文"Cloud Foundry Enterprise Messaging Webhooks?"中的早期配置、设置和开发。

这个博客的前提条件是:

1。在企业消息传递驾驶舱中配置的一个名为"ErrorQueue"的队列。

2。停止先前创建的节点.jsSAP CF空间中的应用程序,按停止图标。

一旦此应用程序停止,店铺淘客怎么做,您将看到"请求状态"已切换到"停止"。

3。删除企业消息传送驾驶舱中当前和早期创建的Webhook订阅。

这是因为节点.js将创建应用程序,该应用程序将使用来自"ErrorQueue"的这些AMQP消息。如果Webhook仍然被订阅,那么它将使用这个队列中的消息,并且新队列将不再使用更多的消息节点.jsAMQP应用程序

由于这些博客文章是关于在一个端到端的组合解决方案中演示所有这些服务的功能,我将简要介绍这个CPI流。

这个流在部署时只运行一次,物联网技术应用,因为它是在"启动计时器"控件中配置的。此流继续使用"触发器错误脚本",其中包含以下代码:

此代码将尝试用字符串7乘以3,这将失败并引发异常。这将调用将捕获此抛出错误的"异常子进程1"。

此"异常子进程1"持有一个"Groovy脚本"控件,其内容如下:

它将创建字节数组,并将字节设置为要发送的消息的正文。

当此JSON有效负载消息未转换为字节数组时,与编码不一致将发生在消费中节点.js应用程序

到"接收器"的传出连接其"适配器类型"为"AMQP",而"传输协议"为"WebSocket"类型。

AMQP"连接"选项卡需要以下配置:

每个实现的"主机"和"路径"都相同。这是因为SAP在Enterprise Messaging Service中已这样设置。此信息可在"Cloud Foundry Space>Service instances>{Your EM Service}>Service Keys>{Your EMService Key}"中找到。

AMQP"Processing"选项卡需要以下配置:

可以找到有关队列和主题(目的地名称)上发送和接收的更多信息此处:

https://help.sap.com/viewer/bf82e6b26456494cbdd197057c09979f/Cloud/en-US/72ac1fad2d34c4886d672e66b22b54b.html

最后一步是在"安全材料"下提供CPI环境中的OAuth2客户端凭据作为新的"OAuth2凭据"。

这是对CPI流程的简要说明。部署此流时,大数据网,每次部署该流时,"ErrorQueue"中的消息数都会以1递增。每次流失败时,流将失败,"异常子进程1"将在"错误队列"中创建消息。

一个新的节点.js将创建应用程序,以设置一个WebSocket,用于侦听"ErrorQueue"队列上的AMQP消息。

SAP HANA Academy已经构建了这样的应用程序,并在上的存储库中共享了它github。将此存储库克隆到本地IDE:

SAP HANA Academy中此应用程序的GitHub存储库可在此处找到:

https://github.com/saphanaacademy/em-consumer

在"内部"mta.yaml公司文件更改带有"企业消息传递服务实例"名称的绿色标记值和带有队列:ErrorQueue".这是因为这是来自CPI的消息订阅的队列。

下一个更改发生在服务器.js"文件。更改以下代码:

代码如下:

在".toString()"函数中更改了编码,并以"Event:"开头将值记录到控制台。

删除文件中的过时代码,返利机器人,因为我们暂时不需要它服务器.js"文件应该是这样的:

使用以下命令将应用程序推送到云铸造空间:

重新部署云平台集成流,并看到来自CPI流的错误消息出现在节点.js云铸造空间应用:

重发消息通过邮递员发送到队列,消息也将被应用程序消费:

本博客介绍了如何通过云平台集成AMQP适配器与WebSocket传输协议发送消息。来自CPI流的错误消息到达专用队列,并由节点.js在Cloud Foundry上运行的应用程序。

在下一篇博客"WebSocket在SAP UI5多目标应用程序中使用企业消息传递?"SAPUI5中的WebSocket和节点.js将解释它们的用法以及如何在UI5应用程序中实时使用企业消息传递消息!

,政务大数据

上一篇阿里云_分布式数在线自助建站系统-据库的特性_测评

下一篇域名备案_百度云盘产业云-和百度网盘一样吗_免费

云市场知识本月排行

云市场知识精选