当前位置: 首页 > news >正文

分享zframe_send使用过程中 的一个小问题

zframe_send函数中,第一个参数是一个指向zframe_t指针的指针。这是因为在发送帧之后,该函数会销毁帧并将你的指针设置为NULL。这样做是为了防止你再次使用已经被销毁的帧。

所以,如果你的发送数据后续还要使用,可以使用zframe_dup函数处理这种情况。 你需要创建一个新的zframe_t指针,并将sendData的内容复制到这个新的帧中,然后发送这个新的帧。

这是一个可能的解决方案:

void messageListeningProcessingBranch(zsock_t *sDataSock, const zframe_t &sendData)
{
    zframe_t *frame = zframe_dup(&sendData);  // 创建一个新的帧并复制sendData的内容
    zframe_send(&frame, sDataSock, 0);  // 发送新的帧
}

在这个函数中,zframe_dup函数会创建一个新的zframe_t对象,并将sendData的内容复制到这个新的对象中。然后,zframe_send函数会发送这个新的帧,并在发送之后销毁它。

附赠一些相关函数的介绍。
使用ZeroMQ库中的zframe模块进行消息的接收和发送。下面是相关函数的使用介绍:

  1. zframe_recv(responder): 这个函数用于从指定的套接字(在这里是responder)接收一个帧。如果接收成功,它将返回一个新的zframe_t对象,否则返回NULL。这个函数会阻塞,直到有一个帧可以接收。

  2. zframe_strdup(frame_recv): 这个函数用于复制一个帧的数据并将其作为一个新的字符串返回。这个字符串需要在使用完毕后通过free()函数释放。

  3. zframe_size(frame_recv): 这个函数用于获取一个帧的大小,以字节为单位。

  4. zsys_info("Received: %s", message): 这个函数用于打印信息。在这里,它被用来打印接收到的消息。

  5. zframe_send(&frame_recv, responder, 0): 这个函数用于将一个帧发送到指定的套接字(在这里是responder)。第三个参数是一个标志,用于指定发送的方式。在这里,它被设置为0,表示这个函数在发送帧后不会销毁它。如果发送成功,这个函数将返回0,否则返回-1。

  6. free(message): 这个函数用于释放之前通过zframe_strdup()函数复制的字符串。

以上代码的组合使用的一个实例如下

zframe_t *frame_recv = zframe_recv(responder);//responder 是创建的接收套接字
if (frame_recv)
{
    char *message = zframe_strdup(frame_recv);

    print_hex(message, zframe_size(frame_recv));
    zsys_info("Received: %s", message);

    zframe_send(&frame_recv, responder, 0);  // 直接转发接收到的消息

    free(message);  // 释放复制的字符串
}

分享一个有趣的 学习链接:https://xxetb.xet.tech/s/HY8za

相关文章:

  • 基于STM32设计的室内环境监测系统(华为云IOT)_2023
  • CTF工具PDF隐写神器wbStego4open安装和详细使用方法
  • QtC++与QToolButton详解
  • 全国手机基站数据!总量近1640000条数据!
  • SPSS协方差分析
  • win10pycharm和anaconda安装和环境配置教程
  • hivesql,sql 函数总结:
  • k8s 1.28安装
  • 【Spring Boot 源码学习】JedisConnectionConfiguration 详解
  • C语言习题整理①
  • CodeWhisperer 的使用心得
  • 用java代码实现QQ第三方登录
  • ZZULIOJ 1104: 求因子和(函数专题) (C/C++)
  • LT396. 旋转函数]
  • Docker DeskTop安装与启动(Windows版本)
  • axios和Ajax
  • AI 女友突然下线,大叔集体「崩溃」;谷歌聊天机器人称谷歌滥用垄断力量丨 RTE 开发者日报 Vol.78
  • 【实战-08】flink 消费kafka自定义序列化
  • QT+SQLite数据库配置和使用
  • 基于SSM的新闻类网站
  • 连续两个交易日涨停,华夏幸福:生产经营活动正常,不存在影响股价波动的重大事宜
  • 苏丹港持续遭无人机袭击,外交部:呼吁各方保护民用设施和平民安全
  • 马上评|中药液涉嫌添加安眠药?药品安全儿戏不得
  • 牛市早报|上市公司重大资产重组新规出炉,4月经济数据将公布
  • 浦江潮涌征帆劲,上海以高质量发展服务全国发展大局
  • 上市公司重大资产重组新规九要点:引入私募“反向挂钩”,压缩审核流程