感谢!找到问题了!
在NanoMQ DDS proxy源码的subscriber.c文件中,订阅时使用了分区。
const char *partitionssub = { “partition” };
qossub = dds_create_qos();
if (opts.partition != NULL)
partitionssub[0] = opts.partition;
dds_qset_partition(qossub, 1, partitionssub);
在我的代码中加入分区即可正常通信了!