快速部署高可用RabbitMQ集群

在界面左侧树单击待查看消息队列环境后的。 单击“消息队列”，切换至消息队列页签。默认展示“全部实例”的“KafkaProducer监控”信息。 图1 查看通信协议 在消息对列页签选择您想要查看的“实例名称”和“监控项”，可以查看该实例在对应采集器下的不同指标集下的应用监控数据。 图2

查看更多 →

如图2所示，采用社区默认单线程创建索引，耗时146.82s。 图2 单线程创建创建索引 通过设置innodb_rds_parallel_index_creation_threads= 4，启用4个线程创建索引。 从图3中可以看到创建索引耗时38.72s，与社区单线程相比速度提升了3.79倍。

查看更多 →

如图2所示，采用社区默认单线程创建索引，耗时146.82s。 图2 单线程创建创建索引 通过设置innodb_rds_parallel_index_creation_threads= 4，启用4个线程创建索引。 从图3中可以看到创建索引耗时38.72s，与社区单线程相比速度提升了3.79倍。

查看更多 →

Consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 Consumer不能频繁加入和退出group，频繁加入和退出，会导致Consumer频繁做rebalance，阻塞消费。

查看更多 →

配置Region Transition恢复线程 操作场景 在故障环境中，由于诸如region 服务器 响应慢，网络不稳定，ZooKeeper节点版本不匹配等各种原因，有可能导致region长时间处于transition下。在region transition下，由于一些region不

查看更多 →

使用多线程Consumer消费消息 功能简介 在使用Consumer API订阅安全Topic并消费基础上，实现了多线程并发消费，可根据Topic的Partition数目启动相应个数的Consumer线程来对应消费每个Partition上的消息。 下面代码片段在com.huawei

查看更多 →

配置Region Transition恢复线程 操作场景 在故障环境中，由于诸如Region服务器响应慢，网络不稳定，ZooKeeper节点版本不匹配等各种原因，有可能导致Region长时间处于Transition下。当Region处于Transition下，由于一些Region

查看更多 →

psessionid bigint streaming线程的父线程。 tlevel integer streaming线程的层级。与执行计划的层级(id)相对应。 smpid integer smp执行模式下并行线程的并行编号。 userid oid session用户的id。 application_name

查看更多 →

psessionid bigint streaming线程的父线程。 tlevel integer streaming线程的层级。与执行计划的层级(id)相对应。 smpid integer smp执行模式下并行线程的并行编号。 userid oid session用户的id。 application_name

查看更多 →

newThreadCount 初始状态线程数量 初始状态线程数量 - INT SUM runnableThreadCount 运行状态线程数量 运行状态线程数量 - INT SUM blockedThreadCount 阻塞状态线程数量 阻塞状态线程数量 - INT SUM waitingThreadCount

查看更多 →

thread_name text 线程名称。 query_id bigint 查询id，对应debug_query_id。 tid bigint 当前线程的线程号。 sessionid bigint 会话id。 lwtid integer 当前线程的轻量级线程号。 psessionid bigint

查看更多 →

Final Blocking Session Id 阻塞会话id。 Session Start 持锁会话开始时间。 Blocked count 被该会话阻塞的会话的数量。 Blocked%Activity 阻塞会话占活跃会话百分比（阻塞会话总数/样本数量）。 Event Caused

查看更多 →

Spark Streaming任务一直阻塞 问题 运行一个Spark Streaming任务，确认有数据输入后，发现没有任何处理的结果。打开Web界面查看Spark Job执行情况，发现如下图所示：有两个Job一直在等待运行，但一直无法成功运行。 图1 Active Jobs 继

查看更多 →

使用多线程Consumer消费消息 功能介绍 在使用Consumer API订阅安全Topic并消费基础上，实现了多线程并发消费，可根据Topic的Partition数目启动相应个数的Consumer线程来对应消费每个Partition上的消息。 下面代码片段在com.huawei

查看更多 →

thread_name text 线程名称。 query_id bigint 查询ID，对应debug_query_id。 tid bigint 当前线程的线程号。 sessionid bigint 会话ID。 lwtid integer 当前线程的轻量级线程号。 psessionid bigint

查看更多 →

返回值 int：如果成功（或者如果发送队列为空），则返回0；如果由于某种原因失败，则返回-1；如果发送队列中的所有数据都发送失败，则返回1。（此情况只有在连接为非阻塞时才能发生），失败原因存到conn->error_message中。 注意事项 在非阻塞连接上发送任何命令或数据之后，调

查看更多 →

psessionid bigint streaming线程的父线程。 tlevel integer streaming线程的层级。与执行计划的层级（id）相对应。 smpid integer smp执行模式下并行线程的并行编号。 userid oid session用户的id。 application_name

查看更多 →

psessionid bigint streaming线程的父线程。 tlevel integer streaming线程的层级。与执行计划的层级(id)相对应。 smpid integer smp执行模式下并行线程的并行编号。 userid oid session用户的id。 application_name

查看更多 →

psessionid bigint streaming线程的父线程。 tlevel integer streaming线程的层级。与执行计划的层级（id）相对应。 smpid integer smp执行模式下并行线程的并行编号。 userid oid session用户的id。 application_name

查看更多 →

Final Blocking Session Id 阻塞会话id。 Session Start 持锁会话开始时间。 Blocked count 被该会话阻塞的会话的数量。 Blocked%Activity 阻塞会话占活跃会话百分比（阻塞会话总数/样本数量）。 Event Caused

查看更多 →

当签入方式{autoflag}为false时，skillid如果为空则不签入任何技能队列；skillid为技能队列ID字符串组，例如1;2;3，最大长度为4000。座席签入的技能队列为此skillid和所配置技能队列的交集。 4 phonelinkage int False 是否话机联动，接续和硬话机联动控制。取值范围：

查看更多 →