Documentation
¶
Index ¶
Constants ¶
View Source
const ( SEND_MESSAGE = 10 // Broker 发送消息 PULL_MESSAGE = 11 // Broker 订阅消息 QUERY_MESSAGE = 12 // Broker 查询消息 QUERY_BROKER_OFFSET = 13 // Broker 查询Broker Offset QUERY_CONSUMER_OFFSET = 14 // Broker 查询Consumer Offset UPDATE_CONSUMER_OFFSET = 15 // Broker 更新Consumer Offset UPDATE_AND_CREATE_TOPIC = 17 // Broker 更新或者增加一个Topic GET_ALL_TOPIC_CONFIG = 21 // Broker 获取所有Topic的配置（Slave和Namesrv都会向Master请求此配置） GET_TOPIC_CONFIG_LIST = 22 // Broker 获取所有Topic配置（Slave和Namesrv都会向Master请求此配置） GET_TOPIC_NAME_LIST = 23 // Broker 获取所有Topic名称列表 UPDATE_BROKER_CONFIG = 25 // Broker 更新Broker上的配置 GET_BROKER_CONFIG = 26 // Broker 获取Broker上的配置 TRIGGER_DELETE_FILES = 27 // Broker 触发Broker删除文件 GET_BROKER_RUNTIME_INFO = 28 // Broker 获取Broker运行时信息 SEARCH_OFFSET_BY_TIMESTAMP = 29 // Broker 根据时间查询队列的Offset GET_MAX_OFFSET = 30 // Broker 查询队列最大Offset GET_MIN_OFFSET = 31 // Broker 查询队列最小Offset GET_EARLIEST_MSG_STORETIME = 32 // Broker 查询队列最早消息对应时间 VIEW_MESSAGE_BY_ID = 33 // Broker 根据消息ID来查询消息 HEART_BEAT = 34 // Broker Client向Client发送心跳，并注册自身 UNREGISTER_CLIENT = 35 // Broker Client注销 CONSUMER_SEND_MSG_BACK = 36 // Broker Consumer将处理不了的消息发回服务器 END_TRANSACTION = 37 // Broker Commit或者Rollback事务 GET_CONSUMER_LIST_BY_GROUP = 38 // Broker 获取ConsumerId列表通过GroupName CHECK_TRANSACTION_STATE = 39 // Broker 主动向Producer回查事务状态 NOTIFY_CONSUMER_IDS_CHANGED = 40 // Broker Broker通知Consumer列表变化 LOCK_BATCH_MQ = 41 // Broker Consumer向Master锁定队列 UNLOCK_BATCH_MQ = 42 // Broker Consumer向Master解锁队列 GET_ALL_CONSUMER_OFFSET = 43 // Broker 获取所有Consumer Offset GET_ALL_DELAY_OFFSET = 45 // Broker 获取所有定时进度 PUT_KV_CONFIG = 100 // Namesrv 向Namesrv追加KV配置 GET_KV_CONFIG = 101 // Namesrv 从Namesrv获取KV配置 DELETE_KV_CONFIG = 102 // Namesrv 从Namesrv获取KV配置 REGISTER_BROKER = 103 // Namesrv 注册一个Broker，数据都是持久化的，如果存在则覆盖配置 UNREGISTER_BROKER = 104 // Namesrv 卸载一个Broker，数据都是持久化的 GET_ROUTEINTO_BY_TOPIC = 105 // Namesrv 根据Topic获取Broker Name、队列数(包含读队列与写队列) GET_BROKER_CLUSTER_INFO = 106 // Namesrv 获取注册到Name Server的所有Broker集群信息 UPDATE_AND_CREATE_SUBSCRIPTIONGROUP = 200 // 创建或更新订阅组 GET_ALL_SUBSCRIPTIONGROUP_CONFIG = 201 // 订阅组配置 GET_TOPIC_STATS_INFO = 202 // 统计信息，获取Topic统计信息 GET_CONSUMER_CONNECTION_LIST = 203 // Consumer连接管理 GET_PRODUCER_CONNECTION_LIST = 204 // Producer连接管理 WIPE_WRITE_PERM_OF_BROKER = 205 // 优雅地向Broker写数据 GET_ALL_TOPIC_LIST_FROM_NAMESERVER = 206 // 从Name Server获取完整Topic列表 DELETE_SUBSCRIPTIONGROUP = 207 // 从Broker删除订阅组 GET_CONSUME_STATS = 208 // 从Broker获取消费状态（进度） SUSPEND_CONSUMER = 209 // Suspend Consumer消费过程 RESUME_CONSUMER = 210 // Resume Consumer消费过程 RESET_CONSUMER_OFFSET_IN_CONSUMER = 211 // 重置Consumer Offset RESET_CONSUMER_OFFSET_IN_BROKER = 212 // 重置Consumer Offset ADJUST_CONSUMER_THREAD_POOL = 213 // 调整Consumer线程池数量 WHO_CONSUME_THE_MESSAGE = 214 // 查询消息被哪些消费组消费 DELETE_TOPIC_IN_BROKER = 215 // 从Broker删除Topic配置 DELETE_TOPIC_IN_NAMESRV = 216 // 从Namesrv删除Topic配置 GET_KV_CONFIG_BY_VALUE = 217 // Namesrv 通过 project 获取所有的 server ip 信息 DELETE_KV_CONFIG_BY_VALUE = 218 // Namesrv 删除指定 project group 下的所有 server ip 信息 GET_KVLIST_BY_NAMESPACE = 219 // 通过NameSpace获取所有的KV List RESET_CONSUMER_CLIENT_OFFSET = 220 // offset 重置 GET_CONSUMER_STATUS_FROM_CLIENT = 221 // 客户端订阅消息 INVOKE_BROKER_TO_RESET_OFFSET = 222 // 通知 broker 调用 offset 重置处理 INVOKE_BROKER_TO_GET_CONSUMER_STATUS = 223 // 通知 broker 调用客户端订阅消息处理 QUERY_TOPIC_CONSUME_BY_WHO = 300 // Broker 查询topic被谁消费 2014-03-21 Add By shijia GET_TOPICS_BY_CLUSTER = 224 // 获取指定集群下的所有 topic 2014-03-26 REGISTER_FILTER_SERVER = 301 // 向Broker注册Filter Server 2014-04-06 Add By shijia REGISTER_MESSAGE_FILTER_CLASS = 302 // 向Filter Server注册Class 2014-04-06 Add By shijia QUERY_CONSUME_TIME_SPAN = 303 // 根据 topic 和 group 获取消息的时间跨度 GET_SYSTEM_TOPIC_LIST_FROM_NS = 304 // 从Namesrv获取所有系统内置 Topic 列表 GET_SYSTEM_TOPIC_LIST_FROM_BROKER = 305 // 从Broker获取所有系统内置 Topic 列表 CLEAN_EXPIRED_CONSUMEQUEUE = 306 // 清理失效队列 GET_CONSUMER_RUNNING_INFO = 307 // 通过Broker查询Consumer内存数据 2014-07-19 Add By shijia QUERY_CORRECTION_OFFSET = 308 // 查找被修正 offset (转发组件） CONSUME_MESSAGE_DIRECTLY = 309 // 通过Broker直接向某个Consumer发送一条消息，并立刻消费，返回结果给broker，再返回给调用方 SEND_MESSAGE_V2 = 310 // Broker 发送消息，优化网络数据包 GET_UNIT_TOPIC_LIST = 311 // 单元化相关 topic GET_HAS_UNIT_SUB_TOPIC_LIST = 312 // 获取含有单元化订阅组的 Topic 列表 GET_HAS_UNIT_SUB_UNUNIT_TOPIC_LIST = 313 // 获取含有单元化订阅组的非单元化 Topic 列表 CLONE_GROUP_OFFSET = 314 // 克隆某一个组的消费进度到新的组 VIEW_BROKER_STATS_DATA = 315 // 查看Broker上的各种统计信息 )
RequestCode: 内部传输协议码 Author: yintongqiang Since: 2017/8/10
View Source
const ( SUCCESS = 0 // 成功 SYSTEM_ERROR = 1 // 发生了未捕获异常 SYSTEM_BUSY = 2 // 由于线程池拥堵，系统繁忙 REQUEST_CODE_NOT_SUPPORTED = 3 // 请求代码不支持 TRANSACTION_FAILED = 4 // 事务失败，添加db失败 FLUSH_DISK_TIMEOUT = 10 // Broker 刷盘超时 SLAVE_NOT_AVAILABLE = 11 // Broker 同步双写，Slave不可用 FLUSH_SLAVE_TIMEOUT = 12 // Broker 同步双写，等待Slave应答超时 MESSAGE_ILLEGAL = 13 // Broker 消息非法 SERVICE_NOT_AVAILABLE = 14 // Broker, Namesrv 服务不可用，可能是正在关闭或者权限问题 VERSION_NOT_SUPPORTED = 15 // Broker, Namesrv 版本号不支持 NO_PERMISSION = 16 // Broker, Namesrv 无权限执行此操作，可能是发、收、或者其他操作 TOPIC_NOT_EXIST = 17 // Broker, Topic不存在 TOPIC_EXIST_ALREADY = 18 // Broker, Topic已经存在，创建Topic PULL_NOT_FOUND = 19 // Broker 拉消息未找到（请求的Offset等于最大Offset，最大Offset无对应消息） PULL_RETRY_IMMEDIATELY = 20 // Broker 可能被过滤，或者误通知等 PULL_OFFSET_MOVED = 21 // Broker 拉消息请求的Offset不合法，太小或太大 QUERY_NOT_FOUND = 22 // Broker 查询消息未找到 SUBSCRIPTION_PARSE_FAILED = 23 // Broker 订阅关系解析失败 SUBSCRIPTION_NOT_EXIST = 24 // Broker 订阅关系不存在 SUBSCRIPTION_NOT_LATEST = 25 // Broker 订阅关系不是最新的 SUBSCRIPTION_GROUP_NOT_EXIST = 26 // Broker 订阅组不存在 TRANSACTION_SHOULD_COMMIT = 200 // producer 事务应该被提交 TRANSACTION_SHOULD_ROLLBACK = 201 // producer 事务应该被回滚 TRANSACTION_STATE_UNKNOW = 202 // producer 事务状态未知 TRANSACTION_STATE_GROUP_WRONG = 203 // producer ProducerGroup错误 NO_BUYER_ID = 204 // 单元化消息，需要设置 buyerId NOT_IN_CURRENT_UNIT = 205 // 单元化消息，非本单元消息 CONSUMER_NOT_ONLINE = 206 // Consumer不在线 CONSUME_MSG_TIMEOUT = 207 // Consumer消费消息超时 )
ResponseCode: 响应码 Author: yintongqiang Since: 2017/8/16
Variables ¶
This section is empty.
Functions ¶
func ParseRequest ¶
func ParseResponse ¶
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.