php开发在线客服系统_app内在线客服

php开发在线客服系统_app内在线客服  在本节中,我们将简要讨论通过PHP在线客服系统源码传输数据的数据传输方法。我们可以发送普通消息或基于时间表的消息。我们将逐一介绍这两种基本类型的消息传递。  完整源码:zxkfym.top  Azure服务总线:MicrosoftAzure服务总线是一种完全托管的云上企业集成消息传递服务,用于将云中运行的任何应用程序、设备和服务连接到任何其他应用程序或服务。该平台充当云上和任何设备上的应用程序的消息传递骨干。  它是如何工作的?使用消息在不同的应用程序和服务之间传输数据。消息为二进制格

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

  在本节中,我们将简要讨论通过PHP在线客服系统源码传输数据的数据传输方法。我们可以发送普通消息或基于时间表的消息。我们将逐一介绍这两种基本类型的消息传递。
  完整源码:zxkfym.top
  Azure 服务总线: Microsoft Azure 服务总线是一种完全托管的云上企业集成消息传递服务,用于将云中运行的任何应用程序、设备和服务连接到任何其他应用程序或服务。该平台充当云上和任何设备上的应用程序的消息传递骨干。

php开发在线客服系统_app内在线客服

 
  它是如何工作的 ?使用消息在不同的应用程序和服务之间传输数据。消息为二进制格式,可以包含 JSON、XML 或仅包含文本。这些消息被放置到应用程序所连接的服务总线上,以便所有或特定用户连接到这个应用程序上,通过套接字服务连接打开可以接收通过服务总线传输的数据。
  消息类型:通过 Azure 服务总线传输的数据消息可以分为两种主要类型,即数据需要按特定计划发送还是需要立即发送。在这里,我们将详细讨论这两个消息传递过程。其中每一个都有自己特定的方法来调用消息传递过程。
  ●立即发送消息: send() 函数调用将消息发送到当前发送方连接到的 Azure 服务总线。此方法进行非异步调用。您还有一个异步版本来提高性能。

  send( IMessage message )

示例代码:

  public static async sendMessage(content: Message): Promise<string> {
  const serviceConnection = AzureServiceBus.createConnection();
  const client = serviceConnection.createQueueClient(""
  + process.env.AZURE_SERVICEBUS_QUEUE);
  const sender = client.createSender();
  let response = "";
  try {
  const scheduledEnqueueTimeUtc
  = moment().utc().add(1, "m").toDate();
  await sender.send( {body: JSON.stringify(content),
  label: "MyTopic"});
  await client.close();
  } catch (error) {
  } finally {
  await serviceConnection.close();
  }
  return resp;
  }

  ●计划消息:此方法将基于计时器的消息发送到调用发件人所连接的 Azure 服务总线。它将消息排入总线以预定时间消息,将消息传递到接收端。这是当前的异步过程,以获得更好的性能。

php开发在线客服系统_app内在线客服

  原型:


  scheduleMessage( IMessage message, Instant scheduledEnqueueTimeUtc )

示例代码:

  public static async sendScheduleMessage(
  content: Message): Promise<string> {
  const serviceConnection =
  AzureServiceBus.createConnection();
  const client = serviceConnection.createQueueClient(
  "" + process.env.AZURE_SERVICEBUS_QUEUE);
  const sender = client.createSender();
  let response = "";
  try {
  const scheduledEnqueueTimeUtc
  = moment().utc().add(1, "m").toDate();
  const sequenceId = await sender.scheduleMessage(
  scheduledEnqueueTimeUtc,
  {body: JSON.stringify(content),
  label: "MyTopic"});
  response = sequenceId.toString();
  await client.close();
  } catch (error) {
  } finally {
  await serviceConnection.close();
  }
  return resp;
  }

  这将引发一个问题,即 sequenceId 值将变为“未定义”。Azure 门户提供了一个修复,即需要对消息进行编码,然后将其放入服务总线中,以便获取正确的 sequenceId。
  错误修复:

  import { DefaultDataTransformer }
  from "@azure/amqp-common";
  ...
  ...
  const dt = new DefaultDataTransformer();
  const sequenceId = await sender.scheduleMessage(
  scheduledEnqueueTimeUtc,
  {body: dt.encode(JSON.stringify(content)),
  label: "MyTopic"});
  response = sequenceId.toString();

  现在您将收到正确的 sequenceId,如果将来需要,您可以使用以下代码段来取消消息。
  CancelMessage:此方法使用 scheduleMessage 调用删除了早期放置在服务总线中的消息。我们需要将调用期间返回的 sequenceNumber 作为此方法调用的唯一参数发送。如果消息已经传递,那么我们会收到一个错误 MessageNotFound ,需要在 catch 中处理。
  原型:

  cancelScheduledMessage( long sequenceNumber )

        因此,我们已经介绍了如何使用上述两种方法进行数据通信,并通过调度或非调度方式放置数据请求。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/193185.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 简单的三数排序,由小到大

    简单的三数排序,由小到大

  • python分组排序_Python 排序分组问题

    python分组排序_Python 排序分组问题_list=[{‘value’:123,’upclock’:1234567},{‘value’:423,’upclock’:2123},{‘value’:123,’upclock’:1234567},{‘value’:423,’upclock’:1123},{‘value’:423,’upclock’:1123},{‘value’:872,’upclock’:…

  • facade模式的好处_fa模式是什么意思

    facade模式的好处_fa模式是什么意思Facade模式使用Facade模式可以为互相关联在一起的错综复杂的类整理出高层接口(API)。其中的Facade角色可以让系统对外只有一个简单的接口(API)。而且,Facade角色还会考虑系统内部各个类之间的责任关系和依赖关系,按照正确的顺序调用各个类。示例程序示例程序类图Databasemportjava.io.FileInputStream;importjava.io….

    2022年10月25日
  • mysql时间戳格式转换日期格式字符串

    mysql时间戳格式转换日期格式字符串1.测试表表结构CREATETABLE`timestamp_string_change`(`id`intNOTNULLAUTO_INCREMENT,`up_time`timestampNULLDEFAULTNULL,PRIMARYKEY(`id`))ENGINE=InnoDBAUTO_INCREMENT=2DEFAULTCHARSET=utf8mb4COLLATE=utf8mb4_0900_ai_ci;2.mysql时间戳格式转字符串方法1

  • MyEclipse 快捷键

    MyEclipse快捷键1(CTRL)Ctrl+1快速修复Ctrl+D:删除当前行 Ctrl+Q定位到最后编辑的地方 Ctrl+L定位在某行Ctrl+O快速显示O

    2021年12月25日
  • 如何测试网站打开速度(网站访问速度)

    检测网站打开速度的5个方法网页载入速度对于一个网站来讲很关键,Google已经将一个网站的载入速度列入了网站关键字排名的考虑因素当中,也就是说如果你的网站有足够的内容,而且载入速度比别人的网站更快一步的话,那么你就是获得更好的排名。那么下面就赶快测试你的网站,提高网站访问速度吧。1:用Ping命令简单测网站速度的方法Ping可以用来检查网络是否通畅或者网络连接速度,点击开始→运行在运行中输…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号