int32_t TcpServerSend(int64_t instance, int64_t server_handle, int64_t conn_id, int64_t data, int32_t data_len)
void OnTcpServerEvent(int64_t server_handle, int64_t conn_id, int32_t event_type,
int64_t data, int32_t data_len, int64_t user_data) {
if (event_type == 1) {
printf("收到数据[conn_id=%lld]:%.*s\n", conn_id, data_len, (char*)data);
const char* reply = "收到消息";
TcpServerSend(instance, server_handle, conn_id, (int64_t)reply, strlen(reply));
}
}
void BroadcastMessage(int64_t server, const char* message) {
const char* connIds = TcpServerGetAllConnectionIds(instance, server);
if (connIds != NULL) {
char* ids = strdup(connIds);
char* token = strtok(ids, ",");
while (token != NULL) {
int64_t conn_id = atoll(token);
TcpServerSend(instance, server, conn_id, (int64_t)message, strlen(message));
token = strtok(NULL, ",");
}
free(ids);
FreeStringPtr(instance, connIds);
}
}