Skip to content

Releases: lnsycmy/NseMQ

NseMQ v1.1.3

17 Nov 13:31
Compare
Choose a tag to compare

生成Release库文件,并实现与kafka-python的互通,具体如下:

新增

  • 生成Visual Studio, MinGW编译器的Release库文件;
  • 调通与kafka-python的数据生产、消费;

修复

  • 修复pthread中PTW32_SCHED_LEVEL的重定义;
  • 修复MinGW x64调用pthread_detach的报错SIGSEGV (Segmentation fault),使用内置Pthread时不再依赖外部头文件和库文件;
  • 修复调用nse_consumer_close()后主程序异常退出问题;
  • 修复消费消息时数据类型不识别问题,重新计算消息key值的长度;

目录说明

  • bin:包含可执行jar包文件avrogen.jar,用于生成数据结构(将json文件转换生成.h和.c文件);
  • example: 包含调试的示例文件,如数据的Schema文件cpx.json,生产者示例程序nsemq_producer_example.c,消费者示例程序nsemq_consumer_example.c
  • include:包含NseMQ所需引用的头文件,使用库文件时仅需引用nsemq.h即可;
  • lib:包含生成的NseMQ库及依赖库文件,按照编译器(MinGWVisual Studio 2010)、平台位数(x86x64)、调试发布(DebugRelease)分别生成库文件。

NseMQ v1.1.2

12 Nov 05:06
Compare
Choose a tag to compare
NseMQ v1.1.2 Pre-release
Pre-release

适配MinGW,并可在CPP文件中引用此库,具体如下:

修复

  • 使用MinGW生成x86和x64依赖库,x64下引用MinGW自带的pthread
  • 添加函数指针的强制类型转换,能够适配CPP文件;
  • 添加头文件的完整注释,提高代码可读性;

下步计划

  • 添加常规属性的配置文件;
  • 实现char * 字符数组(无序列化)的数据生产、数据消费。

NseMQ v1.1.1

05 Nov 14:51
Compare
Choose a tag to compare
NseMQ v1.1.1 Pre-release
Pre-release

适配MinGW并生成x64和x86的库文件:

新增

  • 使用MinGW生成依赖库;
  • 兼容Visual Studio和MinGW,并生成了对应库;

下步计划

  • 添加常规属性的配置文件;
  • 实现char * 字符数组(无序列化)的数据生产、数据消费。

NseMQ v1.1.0

02 Nov 11:07
Compare
Choose a tag to compare

优化了C版本的NseMQ相关接口和实现,具体如下:

新增

  • 添加nsemq_consume_start()的同步和异步标签;
  • 添加nsemq_consume_stop()停止消费接口;

修复

  • 接收数据的类型与订阅时指定的数据类型不一致问题;
  • 订阅宏定义改成小写,并取消实际函数的API;
  • 调整消费者API的调用控制逻辑,start和stop;
  • 修复30s后,consumer自动停的问题;
  • 修复subscription方法的参数类型为list;

下步计划

  • 添加常规属性的配置文件;
  • 实现char * 字符数组(无序列化)的数据生产、数据消费。

NseMQ v1.0.0

25 Oct 07:17
Compare
Choose a tag to compare

初步实现了C版本的NseMQ,支持在Visual Studio上配置使用。

已完成

  • 生产者可以直接生产结构体对象,发送到broker;
  • 消费者可以从broker获取数据,并直接消费结构体对象;
  • 消费者内置线程实现定期拉取数据,支持异步消费;
  • 消费者使用全局唯一的group.instance.id,支持在同一主机上多开消费者;
  • 打印的日志默认通过stderr输出。

待完善

  • 添加常规属性的配置文件;
  • 将操作日志打印到日志文件;
  • 实现字符数组(无序列化)的数据生产、数据消费。