OLA 文档中心

主题

2026-06-18

声明消息队列 - MessageQueueDeclare ​

函数简介 ​

声明消息队列并创建发布端句柄。
同一 queue_name 支持多个消费者竞争消费（非广播）。

接口名称 ​

MessageQueueDeclare

DLL调用 ​

c
int64_t MessageQueueDeclare(int64_t instance, int32_t type, int32_t connect_type,
                            char* ip, int32_t port, char* queue_name);

参数说明 ​

参数名类型说明
instance长整数型OLA 实例句柄。
type整数型角色：CLIENT/SERVER（建议 CLIENT）。
connect_type整数型连接类型：TCP/PRO。
ip字符串TCP 模式服务地址；PRO 模式可为空。
port整数型TCP 端口；PRO 模式为 0。
queue_name字符串队列名（非空）。

示例 ​

SDK 调用 ​

cpp
#include "OLAPlugServer.h"

OLAPlugServer ola;
long producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    // producer 为发布端句柄
    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)
{
    // producer 为发布端句柄
    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:
    # producer 为发布端句柄
    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) {
    // producer 为发布端句柄
    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) {
    // producer 为发布端句柄
    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
    // producer 为发布端句柄
    ola.MessageQueueClose(producer)
End If
text
.局部变量 ola, OLAPlug
ola.创建 ()
producer ＝ ola.MessageQueueDeclare (1, 1, "127.0.0.1", 18890, "task_queue")
.如果真 (producer ＞ 0)
    // producer 为发布端句柄
    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){
    // producer 为发布端句柄
    ola.MessageQueueClose(producer);
}
text
变量 ola <类型 = OLAPlugServer>
ola = 新建 OLAPlugServer
长整数 producer = ola.MessageQueueDeclare(1, 1, "127.0.0.1", 18890, "task_queue")
如果真 (producer ＞ 0)
{
    // producer 为发布端句柄
    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) {
    // producer 为发布端句柄
    ola.MessageQueueClose(producer);
}

原生 DLL 调用 ​

cpp
long instance = CreateCOLAPlugInterFace();
long producer = MessageQueueDeclare(instance, 1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    // 使用 producer 发布消息
    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);

long instance = CreateCOLAPlugInterFace();
long producer = MessageQueueDeclare(instance, 1, 1, "127.0.0.1", 18890, "task_queue");
if (producer > 0) {
    // 使用 producer 发布消息
    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:
    // 使用 producer 发布消息
    ola.MessageQueueClose(instance, producer)

返回值 ​

返回值说明
（返回值）大于 0 为队列发布句柄；<=0 为错误码。