OLA 文档中心

主题

2026-06-18

发布队列二进制消息 - MessageQueuePublishBytes ​

函数简介 ​

发布二进制消息到指定队列。

接口名称 ​

MessageQueuePublishBytes

DLL调用 ​

c
int32_t MessageQueuePublishBytes(int64_t instance, int64_t producer,
                                 int64_t data_ptr, int32_t data_len);

参数说明 ​

参数名类型说明
instance长整数型OLA 实例句柄。
producer长整数型发布端句柄。
data_ptr长整数型数据指针（可为 0，表示空负载）。
data_len整数型数据长度（字节）。

示例 ​

SDK 调用 ​

cpp
#include "OLAPlugServer.h"

OLAPlugServer ola;
long producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    int ret = ola.MessageQueuePublishBytes(producer, dataPtr, 4);
    ola.MessageQueueClose(producer);
}
csharp
using OLAPlug;

var ola = new OLAPlugServer();
long producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0)
{
    int ret = ola.MessageQueuePublishBytes(producer, dataPtr, 4);
    ola.MessageQueueClose(producer);
}
python
from OLAPlugServer import OLAPlugServer

ola = OLAPlugServer()
producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue")
if producer > 0:
    ret = ola.MessageQueuePublishBytes(producer, data_ptr, 4)
    ola.MessageQueueClose(producer)
java
import com.olaplug.OLAPlugServer;

OLAPlugServer ola = new OLAPlugServer();
long producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    ola.MessageQueuePublishBytes(producer, 0, 0);
    ola.MessageQueueClose(producer);
}
cpp
var ola = com("OlaPlug.OlaSoft")
var producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue")
if(producer > 0) {
    ola.MessageQueuePublishBytes(producer, 0, 0);
    ola.MessageQueueClose(producer)
}
vbscript
Set ola = CreateObject("OlaPlug.OlaSoft")
producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue")
If producer > 0 Then
    ola.MessageQueuePublishBytes(producer, 0, 0);
    ola.MessageQueueClose(producer)
End If
text
.局部变量 ola, OLAPlug
ola.创建 ()
producer ＝ ola.MessageQueueDeclare (1, 1, "127.0.0.1", 18890, "task_queue")
.如果真 (producer ＞ 0)
    ola.MessageQueuePublishBytes(producer, 0, 0);
    ola.MessageQueueClose (producer)
.如果真结束
aardio
import OLAPlugServer;
var ola = OLAPlugServer();
var producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue");
if(producer > 0){
    ola.MessageQueuePublishBytes(producer, 0, 0);
    ola.MessageQueueClose(producer);
}
text
变量 ola <类型 = OLAPlugServer>
ola = 新建 OLAPlugServer
长整数 producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue")
如果真 (producer ＞ 0)
{
    ola.MessageQueuePublishBytes(producer, 0, 0);
    ola.MessageQueueClose(producer)
}
cpp
#include "OLAPlugServer.h"

OLAPlugServer ola;
long producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    ola.MessageQueuePublishBytes(producer, 0, 0);
    ola.MessageQueueClose(producer);
}

原生 DLL 调用 ​

cpp
long instance = CreateCOLAPlugInterFace();
long producer = MessageQueueDeclare(instance, 1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    int ret = MessageQueuePublishBytes(instance, producer, dataPtr, 4);
    MessageQueueClose(instance, producer);
}
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 MessageQueueDeclare(long ola, int type, int connect_type, string ip, int port, string queue_name);
[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern int MessageQueueClose(long ola, long producer);
[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern int MessageQueuePublishBytes(long ola, long producer, long data_ptr, int data_len);

long instance = CreateCOLAPlugInterFace();
long producer = MessageQueueDeclare(instance, 1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    int ret = MessageQueuePublishBytes(instance, producer, dataPtr, 4);
    MessageQueueClose(instance, producer);
}
python
from ctypes import CDLL, c_int, c_int64

ola = CDLL("OLAPlug_x64.dll")
ola.CreateCOLAPlugInterFace.restype = c_int64
instance = ola.CreateCOLAPlugInterFace()
producer = ola.MessageQueueDeclare(instance, 1, 1, b"127.0.0.1", 18890, b"task_queue")
if producer:
    int ret = ola.MessageQueuePublishBytes(instance, producer, dataPtr, 4);
    ola.MessageQueueClose(instance, producer)

返回值 ​

返回值说明
（返回值）大于等于 0 为投递数量；<0 为错误码。