设置临时频道订阅者

curl -X POST "http://localhost:5001/tmpchannel/subscriber_set" \
  -H "Content-Type: application/json" \
  -d '{
    "channel_id": "tmp_channel_123",
    "uids": ["user1", "user2", "user3"]
  }'

const response = await fetch('http://localhost:5001/tmpchannel/subscriber_set', {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    channel_id: 'tmp_channel_123',
    uids: ['user1', 'user2', 'user3']
  })
});

const data = await response.json();
console.log(data);

import requests

data = {
    "channel_id": "tmp_channel_123",
    "uids": ["user1", "user2", "user3"]
}

response = requests.post('http://localhost:5001/tmpchannel/subscriber_set', json=data)
result = response.json()
print(result)

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "net/http"
)

func main() {
    data := map[string]interface{}{
        "channel_id": "tmp_channel_123",
        "uids":       []string{"user1", "user2", "user3"},
    }
    
    jsonData, _ := json.Marshal(data)
    
    resp, err := http.Post(
        "http://localhost:5001/tmpchannel/subscriber_set",
        "application/json",
        bytes.NewBuffer(jsonData),
    )
    if err != nil {
        panic(err)
    }
    defer resp.Body.Close()
    
    var result map[string]interface{}
    json.NewDecoder(resp.Body).Decode(&result)
    fmt.Printf("%+v\n", result)
}

{
  "status": "ok"
}

POST

tmpchannel

subscriber_set

curl -X POST "http://localhost:5001/tmpchannel/subscriber_set" \
  -H "Content-Type: application/json" \
  -d '{
    "channel_id": "tmp_channel_123",
    "uids": ["user1", "user2", "user3"]
  }'

const response = await fetch('http://localhost:5001/tmpchannel/subscriber_set', {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    channel_id: 'tmp_channel_123',
    uids: ['user1', 'user2', 'user3']
  })
});

const data = await response.json();
console.log(data);

import requests

data = {
    "channel_id": "tmp_channel_123",
    "uids": ["user1", "user2", "user3"]
}

response = requests.post('http://localhost:5001/tmpchannel/subscriber_set', json=data)
result = response.json()
print(result)

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "net/http"
)

func main() {
    data := map[string]interface{}{
        "channel_id": "tmp_channel_123",
        "uids":       []string{"user1", "user2", "user3"},
    }
    
    jsonData, _ := json.Marshal(data)
    
    resp, err := http.Post(
        "http://localhost:5001/tmpchannel/subscriber_set",
        "application/json",
        bytes.NewBuffer(jsonData),
    )
    if err != nil {
        panic(err)
    }
    defer resp.Body.Close()
    
    var result map[string]interface{}
    json.NewDecoder(resp.Body).Decode(&result)
    fmt.Printf("%+v\n", result)
}

{
  "status": "ok"
}

此接口主要用于系统内部调用，用于集群节点间通信。不建议外部直接使用。

概述

设置临时频道的订阅者。这是一个内部API，用于集群节点间通信来管理临时频道订阅。临时频道用于特殊场景，如临时群组或会话，会自动创建和管理频道标签（tag）。

请求体

必传参数

string

必填

临时频道ID，不能包含特殊字符

array

必填

要设置为临时频道订阅者的用户ID列表

string

用户ID

curl -X POST "http://localhost:5001/tmpchannel/subscriber_set" \
  -H "Content-Type: application/json" \
  -d '{
    "channel_id": "tmp_channel_123",
    "uids": ["user1", "user2", "user3"]
  }'

const response = await fetch('http://localhost:5001/tmpchannel/subscriber_set', {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    channel_id: 'tmp_channel_123',
    uids: ['user1', 'user2', 'user3']
  })
});

const data = await response.json();
console.log(data);

import requests

data = {
    "channel_id": "tmp_channel_123",
    "uids": ["user1", "user2", "user3"]
}

response = requests.post('http://localhost:5001/tmpchannel/subscriber_set', json=data)
result = response.json()
print(result)

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "net/http"
)

func main() {
    data := map[string]interface{}{
        "channel_id": "tmp_channel_123",
        "uids":       []string{"user1", "user2", "user3"},
    }
    
    jsonData, _ := json.Marshal(data)
    
    resp, err := http.Post(
        "http://localhost:5001/tmpchannel/subscriber_set",
        "application/json",
        bytes.NewBuffer(jsonData),
    )
    if err != nil {
        panic(err)
    }
    defer resp.Body.Close()
    
    var result map[string]interface{}
    json.NewDecoder(resp.Body).Decode(&result)
    fmt.Printf("%+v\n", result)
}

{
  "status": "ok"
}

响应字段

string

必填

操作状态，成功时返回 "ok"

状态码

状态码	说明
200	临时频道订阅者设置成功
400	请求参数错误
500	服务器内部错误

临时频道机制

临时频道特点

临时性：用于特殊场景的临时群组或会话
自动管理：系统自动创建和管理频道标签
集群通信：主要用于集群节点间的内部通信
订阅管理：支持动态设置订阅者列表

使用场景

场景	说明	适用情况
临时群组	创建临时的讨论群组	短期项目协作
会话迁移	在集群节点间迁移会话	负载均衡
系统维护	临时重组频道结构	系统升级

注意事项

内部API警告此接口设计用于系统内部调用，直接使用可能导致：

数据不一致
集群状态异常
意外的系统行为

建议使用标准的频道管理接口进行常规操作。

参数限制

频道ID：不能为空，不能包含特殊字符
用户列表：至少包含一个用户ID
字符长度：频道ID最大64字符

错误处理

错误信息	原因	解决方案
channel_id不能为空	未提供频道ID	确保提供有效的频道ID
uids不能为空	用户列表为空	提供至少一个用户ID
频道ID不能包含特殊字符	频道ID格式无效	使用字母数字和下划线
获取频道所在节点失败	集群通信错误	检查集群状态
创建标签失败	标签系统错误	检查标签服务状态

最佳实践

仅内部使用：避免在客户端应用中直接调用
参数验证：确保所有参数格式正确
错误处理：实现完整的错误处理机制
监控日志：记录API调用以便问题排查
集群状态：确保集群状态正常再调用

路由管理

消息管理

频道管理

用户管理

会话管理

连接管理

事件管理

监控

系统

集成接口

管理员

设置临时频道订阅者

概述

请求体

必传参数

响应字段

状态码

临时频道机制

临时频道特点

使用场景

注意事项

参数限制

错误处理

最佳实践

相关接口

​概述

​请求体

​必传参数

​响应字段

​状态码

​临时频道机制

​临时频道特点

​使用场景

​注意事项

​参数限制

​错误处理

​最佳实践

​相关接口

概述

请求体

必传参数

响应字段

状态码

临时频道机制

临时频道特点

使用场景

注意事项

参数限制

错误处理

最佳实践

相关接口