消息队列

本文介绍消息队列客户端的故障配置参数。

Kafka 故障

脏数据

• 可注入目标：

  • 集群中的中间件
  • 主机中的中间件

• 故障参数：

  参数	是否必填	说明
  故障名称	是	故障的名称。
  Host	是	数据库客户端的 IP。
  端口	是	数据库客户端的端口号。
  是否需要用户名密码	是	选择是否需要输入账户和密码登录。选择是，则需要配置对应的用户名和密码。
  用户名	是	数据库账号的用户名。
  密码	是	数据库账号的密码。
  脏数据值	是	注入脏数据的数据值。
  Kafka Topic	是	脏数据注入的目标 Topic。

重复数据

• 可注入目标：

  • 集群中的中间件
  • 主机中的中间件

• 故障参数：

  参数	是否必填	说明
  故障名称	是	故障的名称。
  Host	是	数据库客户端的 IP。
  端口	是	数据库客户端的端口号。
  是否需要用户名密码	是	选择是否需要输入账户和密码登录。选择是，则需要配置对应的用户名和密码。
  用户名	是	数据库账号的用户名。
  密码	是	数据库账号的密码。
  数据值	是	注入重复数据的数据值。
  Kafka Topic	是	脏数据注入的目标 Topic。
  重复数据条数	是	注入重复数据的条数。
  持续时间	是	故障注入持续的时长。

RocketMQ 故障

脏数据

• 可注入目标：

  • 集群中的中间件
  • 主机中的中间件

• 故障参数：

  参数	是否必填	说明
  故障名称	是	故障的名称。
  Host	是	数据库客户端的 IP。
  端口	是	数据库客户端的端口号。
  是否需要用户名密码	是	选择是否需要输入账户和密码登录。选择是，则需要配置对应的用户名和密码。
  用户名	是	数据库账号的用户名。
  密码	是	数据库账号的密码。
  脏数据值	是	注入脏数据的数据值。
  Topic	是	脏数据注入的目标 Topic。

重复数据

• 可注入目标：

  • 集群中的中间件
  • 主机中的中间件

• 故障参数：

  参数	是否必填	说明
  故障名称	是	故障的名称。
  Host	是	数据库客户端的 IP。
  端口	是	数据库客户端的端口号。
  是否需要用户名密码	是	选择是否需要输入账户和密码登录。选择是，则需要配置对应的用户名和密码。
  用户名	是	数据库账号的用户名。
  密码	是	数据库账号的密码。
  数据值	是	注入重复数据的数据值。
  Topic	是	脏数据注入的目标 Topic。
  重复数据条数	是	注入重复数据的条数。
  持续时间	是	故障注入持续的时长。

RabbitMQ 故障

脏数据

• 可注入目标：

  • 集群中的中间件
  • 主机中的中间件

• 故障参数：

  参数	是否必填	说明
  故障名称	是	故障的名称。
  Host	是	数据库客户端的 IP。
  端口	是	数据库客户端的端口号。
  是否需要用户名密码	是	选择是否需要输入账户和密码登录。选择是，则需要配置对应的用户名和密码。
  用户名	是	数据库账号的用户名。
  密码	是	数据库账号的密码。
  Queue	否	Queue 名称。可以指定 Queue 或指定 Exchange注入，指定 Exchange会根据规则向已绑定的相应的Queue注入。Queue 和 Exchange 至少需要填一个。
  Queue 持久化属性	否	选择 Queue 的持久化属性。支持 durable 和 transient 类型。 durable：持久化保存，关机或重启后依然存在。 transient：即时保存，关机或重启后不存在。
  Exchange	否	Exchange 名称。可以指定 Queue 或指定 Exchange注入，指定 Exchange会根据规则向已绑定的相应的Queue注入。Queue 和 Exchange 至少需要填一个。
  Exchange 持久化属性	否	选择 Exchange 的持久化属性。支持 durable 和 transient 类型。 durable：持久化保存，关机或重启后依然存在。 transient：即时保存，关机或重启后不存在。
  Exchange 类型	否	选择 Exchange 的类型，目前支持 fanout 和 direct。 fanout：会向 Exchange 绑定的所有 Queue 发送 Message，不需要 Routing Key。 direct：根据 Routing Key 向 Exchange 绑定的对应的 Queue 发送 Message，需要 Routing Key。
  Routing Key	否	Exchange 和 Queue 绑定时使用的 Routing Key。
  脏数据值	是	注入脏数据的数据值。

重复数据

• 可注入目标：

  • 集群中的中间件
  • 主机中的中间件

• 故障参数：

  参数	是否必填	说明
  故障名称	是	故障的名称。
  Host	是	数据库客户端的 IP。
  端口	是	数据库客户端的端口号。
  是否需要用户名密码	是	选择是否需要输入账户和密码登录。选择是，则需要配置对应的用户名和密码。
  用户名	是	数据库账号的用户名。
  密码	是	数据库账号的密码。
  Queue	否	Queue 名称。可以指定 Queue 或指定 Exchange注入，指定 Exchange会根据规则向已绑定的相应的Queue注入。Queue 和 Exchange 至少需要填一个。
  Queue 持久化属性	否	选择 Queue 的持久化属性。支持 durable 和 transient 类型。 durable：持久化保存，关机或重启后依然存在。 transient：即时保存，关机或重启后不存在。
  Exchange	否	Exchange 名称。可以指定 Queue 或指定 Exchange注入，指定 Exchange会根据规则向已绑定的相应的Queue注入。Queue 和 Exchange 至少需要填一个。
  Exchange 持久化属性	否	选择 Exchange 的持久化属性。支持 durable 和 transient 类型。 durable：持久化保存，关机或重启后依然存在。 transient：即时保存，关机或重启后不存在。
  Exchange 类型	否	选择 Exchange 的类型，目前支持 fanout 和 direct。 fanout：会向 Exchange 绑定的所有 Queue 发送 Message，不需要 Routing Key。 direct：根据 Routing Key 向 Exchange 绑定的对应的 Queue 发送 Message，需要 Routing Key。
  Routing Key	否	Exchange 和 Queue 绑定时使用的 Routing Key。
  数据值	是	注入重复数据的数据值。
  数量	是	注入重复数据的条数。
  持续时间	是	故障注入持续的时长。