OLA 文档中心

主题

2026-06-18

发布文本消息 - PubSubPubText ​

函数简介 ​

向指定主题发布文本消息。

接口名称 ​

PubSubPubText

DLL调用 ​

c
int32_t PubSubPubText(int64_t instance, int64_t client, char* topic, char* text);

参数说明 ​

参数名类型说明
instance长整数型OLA 实例句柄。
client长整数型Pub/Sub 句柄。
topic字符串主题名（非空）。
text字符串文本消息内容。

示例 ​

SDK 调用 ​

cpp
#include "OLAPlugServer.h"

OLAPlugServer ola;
// type=1 CLIENT, connect_type=1 TCP；回调传 nullptr 表示仅发布
long pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, nullptr);
if (pubsub > 0) {
    int ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola");
    ola.PubSubFree(pubsub);
}
csharp
using OLAPlug;

var ola = new OLAPlugServer();
// type=1 CLIENT, connect_type=1 TCP
long pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, null);
if (pubsub > 0)
{
    int ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola");
    ola.PubSubFree(pubsub);
}
python
from OLAPlugServer import OLAPlugServer

ola = OLAPlugServer()
pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, None)
if pubsub > 0:
    ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola")
    ola.PubSubFree(pubsub)
java
import com.olaplug.OLAPlugServer;

OLAPlugServer ola = new OLAPlugServer();
long pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, null);
if (pubsub > 0) {
    int ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola");
    ola.PubSubFree(pubsub);
}
cpp
var ola = com("OlaPlug.OlaSoft")
var pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, 0)
if(pubsub > 0) {
    var ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola")
    ola.PubSubFree(pubsub)
}
vbscript
Set ola = CreateObject("OlaPlug.OlaSoft")
pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, 0)
If pubsub > 0 Then
    ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola")
    ola.PubSubFree(pubsub)
End If
text
.局部变量 ola, OLAPlug
ola.创建 ()
pubsub ＝ ola.PubSubNew (1, 1, "127.0.0.1", 18890, 0)
.如果真 (pubsub ＞ 0)
    ret ＝ ola.PubSubPubText (pubsub, "topic/demo", "hello ola")
    ola.PubSubFree (pubsub)
.如果真结束
aardio
import OLAPlugServer;
var ola = OLAPlugServer();
var pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, null);
if(pubsub > 0){
    var ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola");
    ola.PubSubFree(pubsub);
}
text
变量 ola <类型 = OLAPlugServer>
ola = 新建 OLAPlugServer
长整数 pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, 0)
如果真 (pubsub ＞ 0)
{
    整数 ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola")
    ola.PubSubFree(pubsub)
}
cpp
#include "OLAPlugServer.h"

OLAPlugServer ola;
long pubsub = ola.PubSubNew(1, 1, "127.0.0.1", 18890, nullptr);
if (pubsub > 0) {
    int32_t ret = ola.PubSubPubText(pubsub, "topic/demo", "hello ola");
    ola.PubSubFree(pubsub);
}

原生 DLL 调用 ​

cpp
long instance = CreateCOLAPlugInterFace();
long pubsub = PubSubNew(instance, 1, 1, "127.0.0.1", 18890, 0);
if (pubsub > 0) {
    int ret = PubSubPubText(instance, pubsub, "topic/demo", "hello ola");
    PubSubFree(instance, pubsub);
}
csharp
using System.Runtime.InteropServices;
using System.Text;

[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern long CreateCOLAPlugInterFace();
[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern long PubSubNew(long ola, int type, int connect_type, string ip, int port, long callback);
[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern int PubSubFree(long ola, long client);
[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern int PubSubPubText(long ola, long client, string topic, string text);

long instance = CreateCOLAPlugInterFace();
long pubsub = PubSubNew(instance, 1, 1, "127.0.0.1", 18890, 0);
if (pubsub > 0) {
    int ret = PubSubPubText(instance, pubsub, "topic/demo", "hello ola");
    PubSubFree(instance, pubsub);
}
python
from ctypes import CDLL, c_int, c_int64

ola = CDLL("OLAPlug_x64.dll")
ola.CreateCOLAPlugInterFace.restype = c_int64
instance = ola.CreateCOLAPlugInterFace()
pubsub = ola.PubSubNew(instance, 1, 1, b"127.0.0.1", 18890)
if pubsub:
    int ret = ola.PubSubPubText(instance, pubsub, "topic/demo", "hello ola");
    ola.PubSubFree(instance, pubsub)

返回值 ​

返回值说明
（返回值）大于等于 0 为收到该消息的订阅端数量；小于 0 为错误码。