Skip to content

服务端发送数据 - TcpServerSend

函数简介

向指定连接发送数据。

接口名称

TcpServerSend

DLL调用

c
int32_t TcpServerSend(int64_t instance, int64_t server_handle, int64_t conn_id, int64_t data, int32_t data_len);

参数说明

参数名类型说明
instance长整数型OLAPlug对象的指针,由 CreateCOLAPlugInterFace 接口生成。
server_handle长整数型服务端句柄。
conn_id长整数型连接ID(从回调中获得)。
data长整数型数据指针。
data_len整数型数据长度。

示例

SDK 调用

cpp
#include "OLAPlugServer.h"

OLAPlugServer ola;
long server = ola.TcpServerCreate("0.0.0.0", 9000, nullptr, 0, 1);
if (server != 0) {
    long connId = 1; // 从回调 event_type=0 获得
    const char* msg = "hello client";
    ola.TcpServerSend(server, connId, (long)msg, (int)strlen(msg));
    ola.TcpServerDestroy(server);
}
csharp
using OLAPlug;

var ola = new OLAPlugServer();
long server = ola.TcpServerCreate("0.0.0.0", 9000, null, 0, 1);
if (server != 0)
{
    long connId = 1;
    byte[] data = System.Text.Encoding.UTF8.GetBytes("hello client");
    ola.TcpServerSend(server, connId, data);
    ola.TcpServerDestroy(server);
}
python
from OLAPlugServer import OLAPlugServer

ola = OLAPlugServer()
server = ola.TcpServerCreate("0.0.0.0", 9000, None, 0, 1)
if server:
    conn_id = 1  # 从回调获得
    ola.TcpServerSend(server, conn_id, b"hello client")
    ola.TcpServerDestroy(server)
java
import com.olaplug.OLAPlugServer;

OLAPlugServer ola = new OLAPlugServer();
long server = ola.TcpServerCreate("0.0.0.0", 9000, null, 0, 1);
if (server != 0) {
    long connId = 1;
    ola.TcpServerSend(server, connId, "hello client".getBytes());
    ola.TcpServerDestroy(server);
}
go
import "github.com/ola/olaplug/olaplug"

ola, _ := olaplug.NewOLAPlugServer("OLAPlug_x64.dll")
defer ola.ReleaseObj()
long server = ola.TcpServerCreate("0.0.0.0", 9000, nil, 0, 1);
if (server != 0) {
    connId := int64(1)
    ola.TcpServerSend(server, connId, []byte("hello client"))
    ola.TcpServerDestroy(server);
}
rust
use olaplug::OLAPlugServer;

let ola = OLAPlugServer::new("OLAPlug_x64.dll").unwrap();
long server = ola.TcpServerCreate("0.0.0.0", 9000, None, 0, 1);
if (server != 0) {
    ola.tcp_server_send(&server, 1, b"hello client");
    ola.TcpServerDestroy(server);
}
cpp
var ola = com("OlaPlug.OlaSoft")
long server = ola.TcpServerCreate("0.0.0.0", 9000, 0, 0, 1);
if (server != 0) {
    var connId = 1
    ola.TcpServerSend(server, connId, "hello client")
    ola.TcpServerDestroy(server);
}
vbscript
Set ola = CreateObject("OlaPlug.OlaSoft")
long server = ola.TcpServerCreate("0.0.0.0", 9000, 0, 0, 1);
if (server != 0) {
    connId = 1
    ola.TcpServerSend(server, connId, "hello client")
    ola.TcpServerDestroy(server);
}
text
.局部变量 ola, OLAPlug
ola.创建 ()
long server = ola.TcpServerCreate("0.0.0.0", 9000, 0, 0, 1);
if (server != 0) {
    connId = 1
    ola.TcpServerSend (server, connId, "hello client")
    ola.TcpServerDestroy(server);
}
aardio
import OLAPlugServer;
var ola = OLAPlugServer();
long server = ola.TcpServerCreate("0.0.0.0", 9000, null, 0, 1);
if (server != 0) {
    var connId = 1;
    ola.TcpServerSend(server, connId, "hello client");
    ola.TcpServerDestroy(server);
}
text
变量 ola <类型 = OLAPlugServer>
ola = 新建 OLAPlugServer
long server = ola.TcpServerCreate("0.0.0.0", 9000, 0, 0, 1);
if (server != 0) {
    长整数 connId = 1
    ola.TcpServerSend(server, connId, "hello client")
    ola.TcpServerDestroy(server);
}
cpp
#include "OLAPlugServer.h"

OLAPlugServer ola;
long server = ola.TcpServerCreate("0.0.0.0", 9000, nullptr, 0, 1);
if (server != 0) {
    long connId = 1;
    ola.TcpServerSend(server, connId, (long)"hello client", 12);
    ola.TcpServerDestroy(server);
}

原生 DLL 调用

cpp
long instance = CreateCOLAPlugInterFace();
long server = TcpServerCreate(instance, "0.0.0.0", 9000, 0, instance, 1);
if (server != 0) {
    long connId = 1;
    const char* msg = "hello client";
    TcpServerSend(instance, server, connId, (long)msg, (int)strlen(msg));
    TcpServerDestroy(instance, server);
}
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 TcpServerCreate(long ola, string bind_addr, int port, long callback, long user_data, int enable_packet_protocol);
[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern int TcpServerDestroy(long ola, long server_handle);
[DllImport("OLAPlug_x64.dll", CallingConvention = CallingConvention.StdCall)]
static extern int TcpServerSend(long ola, long server_handle, long conn_id, long data, int data_len);

long instance = CreateCOLAPlugInterFace();
long server = TcpServerCreate(instance, "0.0.0.0", 9000, 0, instance, 1);
if (server != 0) {
    long connId = 1;
    const char* msg = "hello client";
    TcpServerSend(instance, server, connId, (long)msg, (int)strlen(msg));
    TcpServerDestroy(instance, server);
}
python
from ctypes import CDLL, c_int, c_int64, create_string_buffer

ola = CDLL("OLAPlug_x64.dll")
ola.CreateCOLAPlugInterFace.restype = c_int64
instance = ola.CreateCOLAPlugInterFace()
server = ola.TcpServerCreate(instance, b"0.0.0.0", 9000, 0, instance, 1)
if server:
    long connId = 1;
    const char* msg = "hello client";
    ola.TcpServerSend(instance, server, connId, (long)msg, (int)strlen(msg));
    ola.TcpServerDestroy(instance, server)

返回值

返回值说明
(返回值)整数型,1 成功(加入发送队列),0 失败。

注意事项

项目说明
这是异步操作这是异步操作,数据会被加入发送队列。
发送完成后会触发回调(event_type=3)发送完成后会触发回调(event_type=3)。
如果启用了分包协议如果启用了分包协议,会自动添加4字节长度前缀。
如果连接不存在如果连接不存在,发送会失败。
数据会被复制数据会被复制,调用后可以立即释放原始数据。