当前位置： 首页 > article >正文

Kafka运维宝典 （三）- Kafka 最大连接数超出限制问题、连接超时问题、消费者消费时间超过限制问题详细介绍

article 2026/5/13 20:34:09

Kafka运维宝典 （三）

文章目录

  • Kafka运维宝典 （三）
  • 一、Kafka Broker 配置中的最大连接数超出限制问题
    • 1. 错误原因
    • 2. 相关 Kafka 配置参数
      • 2.1 `connections.max`
      • 2.2 `max.connections.per.ip`
      • 2.3 `num.network.threads`
      • 2.4 `connections.max.idle.ms`
    • 3. 错误表现和影响
      • 3.1 连接数超限的影响
    • 4. 解决方案
      • 4.1 增加最大连接数限制
      • 4.2 增加每个 IP 地址的最大连接数
      • 4.3 增加 Kafka Broker 网络线程数
      • 4.4 优化连接池管理
      • 4.5 缩短空闲连接的最大时长
      • 4.6 分布式部署和负载均衡
    • 5. 具体实例
  • 二、Kafka 连接超时问题
    • 1. 连接超时的常见原因
      • 1.1 Kafka Broker 网络延迟或不可用
      • 1.2 客户端与 Broker 之间的连接池问题
      • 1.3 客户端配置不当
      • 1.4 Broker 负载过高或线程不足
      • 1.5 DNS 或代理问题
    • 2. Kafka 连接超时相关配置参数
      • 2.1 `connections.max.idle.ms`
      • 2.2 `request.timeout.ms`
      • 2.3 `connection.timeout.ms`
      • 2.4 `session.timeout.ms`
      • 2.5 `metadata.fetch.timeout.ms`
      • 2.6 `retry.backoff.ms`
    • 3. 常见错误和表现
    • 4. 解决方案
      • 4.1 增加连接超时和请求超时
      • 4.2 增加 Kafka Broker 网络线程数
      • 4.3 检查网络连接
      • 4.4 优化客户端重试策略
      • 4.5 增加 Kafka Broker 资源
      • 4.6 检查网络质量
      • 4.7 使用负载均衡
    • 5. 具体实例
  • 三、Kafka 消费者消费时间超过限制问题
    • 1. 问题现象
      • 1.1 消费超时错误
      • 1.2 消费者组出现重平衡
      • 1.3 消息堆积（Backlog）
      • 1.4 消费者心跳超时
    • 2. 排查方向
      • 2.1 消费者处理时间过长
      • 2.2 Kafka 配置不当
      • 2.3 消费者并发性不足
      • 2.4 Kafka Broker 响应缓慢
      • 2.5 消息堆积与分区不均衡
    • 3. 相关配置参数
      • 3.1 `max.poll.interval.ms`
      • 3.2 `session.timeout.ms`
      • 3.3 `max.poll.records`
      • 3.4 `fetch.max.wait.ms`
      • 3.5 `fetch.min.bytes`
    • 4. 解决方案
      • 4.1 增加消费时间限制
      • 4.2 优化消费者处理速度
      • 4.3 调整 `max.poll.records`
      • 4.4 增加消费者并发性
      • 4.5 调整 `session.timeout.ms`
      • 4.6 确保 Kafka Broker 性能
      • 4.7 分区均衡
    • 5. 具体实例

一、Kafka Broker 配置中的最大连接数超出限制问题

Kafka 在高负载情况下可能会面临 最大连接数限制 达到上限的问题，导致新的客户端连接请求被拒绝。Kafka Broker 允许配置一定的最大连接数，当连接数达到配置的上限时，新的连接会被拒绝。这种情况通常发生在大量客户端（生产者、消费者）连接 Kafka Broker，或者当 Kafka Broker 配置不当时。

1. 错误原因

Kafka Broker 有多个配置参数来限制连接数，这些参数确保 Kafka 集群不会因为连接数过多而导致资源耗尽或性能问题。当客户端（生产者、消费者等）请求与 Broker 建立连接时，如果当前连接数已达到 Broker 的最大连接数限制，Kafka 将拒绝该请求，通常表现为如下错误信息：

[Broker id: 1] Error accepting connection (max connections exceeded)

或者：

Rejected connection from x.x.x.x, address already has the configured maximum of 256 connections

2. 相关 Kafka 配置参数

以下是与 Kafka Broker 连接数限制相关的主要配置参数：

2.1 connections.max

这个配置项用于控制 Kafka Broker 上可以接受的最大连接数。如果 Broker 达到了这个连接数限制，新的客户端连接请求会被拒绝。

connections.max=5000  # 配置允许最大 5000 个并发连接

2.2 max.connections.per.ip

此参数控制来自同一 IP 地址的最大连接数。如果一个 IP 地址的连接数达到配置的上限，来自该 IP 地址的其他连接请求将被拒绝。

max.connections.per.ip=256  # 限制每个 IP 地址最多 256 个连接

2.3 num.network.threads

这个参数定义了 Kafka Broker 处理网络请求的线程数。网络线程不足可能导致连接处理变慢，从而导致客户端连接请求被拒绝。

num.network.threads=8  # 设置为 8，增加网络线程数

2.4 connections.max.idle.ms

该参数定义了连接在无活动时的最大空闲时间。如果连接超过这个时间未被使用，Kafka Broker 会关闭该连接并释放资源。

connections.max.idle.ms=600000  # 10分钟后关闭空闲连接

3. 错误表现和影响

当 Kafka Broker 达到最大连接数限制时，客户端连接会受到拒绝。表现为以下错误信息：

  • 生产者或消费者客户端连接 Kafka 时出现连接失败，错误信息中通常会包含“连接被拒绝”或“最大连接数超限”等字样。
  • Kafka Broker 日志会记录类似的错误：
    [Broker id: 1] Error accepting connection (max connections exceeded)
  • 连接拒绝后，客户端可能会抛出以下异常：
    • 生产者异常：
      [Producer clientId=producer-1] Connection to node -1 could not be established
    • 消费者异常：
      [Consumer clientId=consumer-1] Unable to connect to Kafka server

3.1 连接数超限的影响

  • 拒绝新连接：当连接数超限时，Kafka 无法接受新连接，生产者或消费者无法向集群发送或接收消息。
  • 性能下降：如果 Kafka Broker 由于连接数过多而无法接受新的连接，可能导致生产者消息积压、消费者无法消费消息，整体性能下降。
  • 资源消耗过大：每个连接都会占用一定的系统资源，如内存和 CPU。如果连接数过多，Kafka Broker 可能会耗尽系统资源，甚至出现宕机或性能下降。

4. 解决方案

4.1 增加最大连接数限制

如果 Kafka Broker 经常出现连接数超限问题，可以通过修改 connections.max 配置项来增加允许的最大连接数。例如：

connections.max=10000  # 增加最大连接数限制

修改配置后，重新启动 Kafka Broker 以使配置生效。

4.2 增加每个 IP 地址的最大连接数

如果问题是由于单个 IP 地址的连接数过多，可以考虑增加 max.connections.per.ip 配置项。通过提高每个 IP 地址的最大连接数限制，可以防止某个客户端过多的连接导致拒绝其他连接。例如：

max.connections.per.ip=512  # 每个 IP 地址最多允许 512 个连接

这也可以帮助缓解来自某个 IP 地址的高并发连接问题。

4.3 增加 Kafka Broker 网络线程数

如果 Kafka Broker 处理连接的网络线程数较少，可以增加 num.network.threads 配置项。这将允许 Kafka Broker 处理更多并发的网络连接请求。例如：

num.network.threads=16  # 配置为 16 个网络线程

更多的网络线程可以提高 Kafka Broker 对连接的处理能力，减少因为线程不足导致的连接请求超时。

4.4 优化连接池管理

  • 生产者端优化：确保生产者客户端连接池的管理得当，不要频繁建立和关闭连接。可以通过设置合适的 acks 参数，减少连接的创建和关闭次数。
  • 消费者端优化：消费者客户端也应避免频繁重连，并且合理配置消费策略，确保连接得到最大利用。

4.5 缩短空闲连接的最大时长

如果连接数超限的原因是由于空闲连接未及时关闭，可以通过缩短 connections.max.idle.ms 参数值，确保空闲连接被快速关闭并释放资源。例如：

connections.max.idle.ms=300000  # 设置空闲连接最大保持时间为 5 分钟

4.6 分布式部署和负载均衡

  • 增加 Kafka Broker 节点：如果单个 Broker 的连接数过多，可以增加 Kafka 集群中的 Broker 节点，分担负载。
  • 使用负载均衡：可以使用负载均衡器（如 Nginx 或 HAProxy）将客户端请求均衡地分配到多个 Kafka Broker 上，避免单个 Broker 负载过高。

5. 具体实例

假设你有一个 Kafka 集群，某个 Broker 频繁出现以下错误：

[Broker id: 1] Error accepting connection (max connections exceeded)

解决步骤：

  1. 检查 connections.max 配置，增加最大连接数限制：

    connections.max=10000  # 将最大连接数增加到 10000

    然后，重新启动 Kafka Broker。

  2. 检查 max.connections.per.ip 配置，确保单个 IP 地址的最大连接数足够大：

    max.connections.per.ip=512  # 每个 IP 地址最大连接数设置为 512

  3. 增加 num.network.threads 配置，提高 Kafka Broker 的网络线程数：

    num.network.threads=16  # 配置为 16 个网络线程

  4. 缩短空闲连接的最大时长，通过调整 connections.max.idle.ms 来释放不活跃连接：

    connections.max.idle.ms=300000  # 设置为 5 分钟

  5. 监控连接数：使用 Prometheus 或 JMX 定期监控 Kafka 的连接数指标，发现连接数过多的现象及时调整配置。

通过这些步骤，可以有效解决 Kafka Broker 由于连接数超限导致拒绝新连接的问题，从而提高 Kafka 集群的稳定性和性能。

二、Kafka 连接超时问题

Kafka 连接超时是指客户端（如生产者、消费者）与 Kafka Broker 之间的连接在规定的时间内未能成功建立或维持，导致请求失败。连接超时问题通常发生在 Kafka 集群负载过高、网络不稳定或配置不当时。解决此问题涉及多个方面，包括网络配置、Kafka 配置以及客户端设置。

1. 连接超时的常见原因

1.1 Kafka Broker 网络延迟或不可用

  • Kafka Broker 可能由于网络延迟、硬件故障或负载过重，导致客户端无法在规定时间内建立连接。
  • 网络中断或不稳定会导致客户端连接超时。

1.2 客户端与 Broker 之间的连接池问题

  • 客户端可能维护着多个与 Kafka Broker 的连接池，如果这些连接池资源被耗尽，客户端尝试新连接时会超时。
  • 例如，如果生产者尝试与多个 Kafka Broker 建立连接，但这些连接的初始化时间过长，可能会导致连接超时。

1.3 客户端配置不当

  • 客户端配置的超时值设置过短，导致在连接过程中出现超时错误。
  • request.timeout.ms 和 connection.timeout.ms 等配置可能设置得过低，造成连接超时。

1.4 Broker 负载过高或线程不足

  • Kafka Broker 本身的负载过高，可能会导致请求被阻塞或延迟，进而导致连接超时。
  • Kafka Broker 上的网络线程数配置不足，处理连接请求的能力有限，容易发生超时问题。

1.5 DNS 或代理问题

  • Kafka 客户端可能无法解析 Kafka Broker 的主机名或 IP 地址。或者代理设置不当，导致客户端与 Broker 的连接失败。

2. Kafka 连接超时相关配置参数

以下是 Kafka 中与连接超时相关的主要配置项：

2.1 connections.max.idle.ms

该参数设置连接空闲的最大时间。如果连接在这个时间内没有任何活动，Kafka Broker 会关闭该连接。

connections.max.idle.ms=600000  # 10分钟后关闭空闲连接

2.2 request.timeout.ms

此参数控制请求的最大等待时间。如果请求超时（没有收到 Kafka Broker 的响应），客户端会抛出超时异常。该参数通常用于生产者和消费者请求。

request.timeout.ms=30000  # 请求超时设置为 30 秒

2.3 connection.timeout.ms

客户端连接 Kafka Broker 的超时时间。如果 Kafka Broker 在指定时间内没有响应，客户端会抛出超时异常。

connection.timeout.ms=10000  # 设置连接超时为 10 秒

2.4 session.timeout.ms

Kafka 消费者的会话超时。消费者会话超时通常用于检测消费者是否仍然活跃。如果消费者在规定时间内没有发送心跳，Broker 会认为消费者已经失效并重新平衡分区。

session.timeout.ms=10000  # 设置消费者会话超时为 10 秒

2.5 metadata.fetch.timeout.ms

此参数指定从 Kafka Broker 获取元数据（如主题、分区信息等）的超时时间。元数据获取超时也可能导致连接超时的错误。

metadata.fetch.timeout.ms=60000  # 元数据获取超时设置为 60 秒

2.6 retry.backoff.ms

如果 Kafka 客户端连接超时或失败，客户端会进行重试。此参数控制重试之间的等待时间。

retry.backoff.ms=1000  # 设置重试之间的间隔时间为 1 秒

3. 常见错误和表现

当 Kafka 连接超时时，常见的错误信息包括：

  • 生产者连接超时错误：
    [Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available.
  • 消费者连接超时错误：
    [Consumer clientId=consumer-1] Unable to connect to Kafka server
  • 网络延迟或超时：
    [Consumer clientId=consumer-1] Timed out waiting for server response
  • 元数据获取超时：
    [Producer clientId=producer-1] Timed out waiting for metadata for topic

这些错误通常表示客户端未能在预定时间内成功与 Broker 建立连接或从 Broker 获取元数据。

4. 解决方案

4.1 增加连接超时和请求超时

如果连接或请求经常超时，尝试增加连接超时 (connection.timeout.ms) 和请求超时 (request.timeout.ms) 配置值。例如：

connection.timeout.ms=30000  # 增加连接超时为 30 秒
request.timeout.ms=60000     # 增加请求超时为 60 秒

这样可以在网络延迟较大的情况下，给 Kafka 客户端更多的时间来建立连接和处理请求。

4.2 增加 Kafka Broker 网络线程数

如果 Kafka Broker 的网络线程数不足，可能会导致连接请求超时。通过增加 num.network.threads 参数值，可以提升 Kafka Broker 的并发处理能力。例如：

num.network.threads=8  # 增加 Kafka Broker 网络线程数为 8

4.3 检查网络连接

  • 确保 Kafka Broker 的网络连接正常，防火墙或安全组规则不阻止客户端的连接请求。
  • 检查 Kafka Broker 的 DNS 是否可解析，确保客户端能够正确找到 Kafka Broker。

4.4 优化客户端重试策略

如果客户端频繁遭遇连接超时，可以通过配置 retry.backoff.ms 来减少重试次数或增加重试间隔，从而减轻 Broker 的负担。例如：

retry.backoff.ms=2000  # 增加重试间隔为 2 秒

4.5 增加 Kafka Broker 资源

如果 Kafka Broker 负载过高，可能需要增加资源（如 CPU、内存）来处理更多的连接请求。确保 Kafka Broker 的硬件资源足够支撑当前负载。

4.6 检查网络质量

  • 如果 Kafka Broker 部署在云环境或远程数据中心，网络质量不佳可能导致连接超时。确保网络带宽和延迟足够支持 Kafka 的连接需求。
  • 使用 ping 或 traceroute 工具检查与 Kafka Broker 的网络延迟。

4.7 使用负载均衡

如果 Kafka 集群的负载过高，可以考虑使用负载均衡（如 Nginx、HAProxy）来均衡客户端的连接请求，避免单个 Broker 的连接数过高。

5. 具体实例

假设你的 Kafka 集群频繁遇到连接超时问题，生产者和消费者在连接时出现以下错误：

[Producer clientId=producer-1] Connection to node -1 could not be established. Broker may not be available.

解决步骤：

  1. 检查 connection.timeout.ms 和 request.timeout.ms 配置，增加超时限制：

    connection.timeout.ms=30000  # 设置连接超时为 30 秒
request.timeout.ms=60000     # 设置请求超时为 60 秒

  2. 增加 Kafka Broker 的网络线程数，提升并发处理能力：

    num.network.threads=8  # 增加网络线程数为 8

  3. 检查 Kafka Broker 和客户端的网络连接，确保没有防火墙或 DNS 配置问题。

  4. 调整重试间隔，减少频繁重试的负担：

    retry.backoff.ms=2000  # 设置重试间隔为 2 秒

  5. 扩展 Kafka 集群，增加更多的 Broker 节点，分散负载，避免单个 Broker 成为瓶颈。

三、Kafka 消费者消费时间超过限制问题

Kafka 消费者消费时间超过限制问题通常发生在消费者处理消息的时间过长，导致消费请求超时或消费者无法及时处理消息，进而影响整个消费者组的消费效率。这种问题如果不及时解决，可能会导致消息积压、消费者重平衡等一系列问题，从而影响系统的整体性能。

1. 问题现象

当 Kafka 消费者的消费时间超过设定的限制时，通常会出现以下现象：

1.1 消费超时错误

消费者在消费消息时，未能在规定时间内处理完当前消息，导致超时错误。

[Consumer clientId=consumer-1] Timed out waiting for server response

或者：

[Consumer clientId=consumer-1] Consumer timeout while fetching messages

1.2 消费者组出现重平衡

当一个消费者长时间无法提交消息偏移量，其他消费者会重新分配其消费的分区，导致消费者组的重平衡。

[Consumer clientId=consumer-1] Group coordinator found: ... Rebalancing consumer group

1.3 消息堆积（Backlog）

由于消费者未能及时处理消息，Kafka topic 中的消息开始堆积，造成队列积压。

Kafka topic 'my_topic' has a backlog of 10,000 messages.

1.4 消费者心跳超时

消费者未能在规定时间内向 Kafka Broker 发送心跳，导致 Kafka 假定该消费者已失效，进而触发分区重新分配。

[Consumer clientId=consumer-1] Consumer group 'my_consumer_group' has failed to heartbeat in time

2. 排查方向

2.1 消费者处理时间过长

如果消费者在处理每条消息时执行了复杂的逻辑（如数据库操作、调用外部 API 或计算密集型操作），可能导致消费者处理速度慢，超过了设定的消费时间限制。

2.2 Kafka 配置不当

Kafka 消费者的一些配置参数如果设置不当，也可能导致超时问题：

  • max.poll.interval.ms：消费者在每次调用 poll() 后，最大允许的时间间隔。如果消费者在此时间内没有调用 poll()，则会触发消费者重平衡。
  • session.timeout.ms：消费者与 Kafka Broker 的心跳超时，影响消费者在 Kafka 中的存活时间。
  • max.poll.records：消费者每次从 Broker 获取的最大消息数。如果设置过高，可能导致消费者处理时间过长。

2.3 消费者并发性不足

如果消费者的处理能力不足（如单线程消费、CPU 或内存资源不足等），则无法及时消费大量消息。

2.4 Kafka Broker 响应缓慢

当 Kafka Broker 负载过高或网络延迟较大时，消费者从 Broker 获取消息的时间可能会被延长，从而导致超时。

2.5 消息堆积与分区不均衡

如果某些分区的消息过多，消费者可能会花费更长时间来处理这些分区中的消息，导致消费时间延长。

3. 相关配置参数

以下是 Kafka 消费者和相关配置中，影响消费时间限制的重要配置项：

3.1 max.poll.interval.ms

此参数指定消费者每次从 Broker 拉取消息后，最大允许的消费时间间隔。如果超过此时间，消费者会被认为“死掉”，触发分区的重新分配。

max.poll.interval.ms=300000  # 5 分钟

3.2 session.timeout.ms

消费者与 Kafka Broker 的心跳超时。如果在指定时间内未能发送心跳，Kafka 会认为消费者失效，触发分区重平衡。

session.timeout.ms=10000  # 设置为 10 秒

3.3 max.poll.records

控制消费者每次调用 poll() 时最多拉取多少条消息。如果拉取的消息过多，可能会导致处理时间过长，进而超时。

max.poll.records=500  # 每次最多拉取 500 条消息

3.4 fetch.max.wait.ms

控制消费者从 Broker 拉取消息时，等待服务器响应的最大时间。如果设置得过低，可能会导致消费者频繁超时。

fetch.max.wait.ms=500  # 设置为 500 毫秒

3.5 fetch.min.bytes

该配置控制每次拉取消息时，Broker 至少返回的消息字节数。如果设置为较高的值，可能会导致消费者等待更多消息，从而超时。

fetch.min.bytes=1  # 设置为 1 字节，确保每次拉取尽可能多的消息

4. 解决方案

4.1 增加消费时间限制

如果消费者处理每条消息需要较长时间，可以通过增加 max.poll.interval.ms 来允许消费者有更长的时间来处理消息。

max.poll.interval.ms=600000  # 增加为 10 分钟

此设置允许消费者在每次拉取消息后有更多时间来完成消息处理，避免因超时被认为是失效消费者。

4.2 优化消费者处理速度

优化消费者处理逻辑，减少每条消息的处理时间：

  • 并行处理：使用多线程或异步处理方式，避免单线程消费过慢。
  • 批量处理：如果消息处理逻辑允许，可以批量处理消息，减少每条消息的处理时间。
  • 数据库操作优化：如果消息处理涉及数据库操作，确保数据库操作高效，如使用批量插入等优化策略。

4.3 调整 max.poll.records

如果消费者一次拉取的消息数量太多，可能会导致消费时间过长。减少每次拉取的消息数量，可以缩短每次 poll() 操作的时间。

max.poll.records=100  # 每次最多拉取 100 条消息

4.4 增加消费者并发性

使用多个消费者实例来增加并发性，减少单个消费者的负载，从而缩短每个消费者的处理时间。

4.5 调整 session.timeout.ms

适当增加 session.timeout.ms 配置项，以减少因心跳超时导致的消费者重平衡。通常可以设置为较大的值，确保消费者即使在短暂的处理延迟下也能正常工作。

session.timeout.ms=15000  # 设置为 15 秒

4.6 确保 Kafka Broker 性能

确保 Kafka Broker 的性能足够支撑客户端的需求，检查 Broker 的 CPU、内存、磁盘等资源是否足够。如果发现 Kafka Broker 的负载过高，可以考虑增加 Kafka Broker 节点或优化 Broker 配置。

4.7 分区均衡

确保 Kafka topic 的分区数量适当，并且分区均衡。某些分区的消息积压可能会导致个别消费者的处理时间延长，影响整个消费者组的消费速度。增加分区数或重新分配分区可以有效缓解该问题。

5. 具体实例

假设你有一个 Kafka 消费者，在消费消息时出现了超时错误：

[Consumer clientId=consumer-1] Timed out waiting for server response

解决步骤：

  1. 增加 max.poll.interval.ms 配置：
    由于消费者的处理逻辑较为复杂，增加 max.poll.interval.ms 配置，允许消费者更长的时间来处理每条消息。

    max.poll.interval.ms=600000  # 增加为 10 分钟

  2. 优化消费者处理速度：

    • 使用多线程异步处理消息，避免长时间占用单个线程。
    • 如果涉及数据库操作，考虑批量处理数据插入，提升效率。

  3. 减少每次拉取的消息数：
    修改 max.poll.records，确保每次 poll() 时拉取的消息数量适中。

    max.poll.records=100  # 每次最多拉取 100 条消息

  4. 确保 Kafka Broker 资源足够：
    检查 Kafka Broker 的 CPU、内存、磁盘等资源是否充足，必要时增加更多 Broker 节点，缓解负载压力。

  5. 增加 session.timeout.ms 配置：
    为了避免因心跳超时导致的消费者重平衡，增加 session.timeout.ms 设置。

    session.timeout.ms=15000  # 设置为 15 秒

相关文章：

Kafka运维宝典 （三）- Kafka 最大连接数超出限制问题、连接超时问题、消费者消费时间超过限制问题详细介绍

Kafka运维宝典 （三） 文章目录 Kafka运维宝典 （三）一、Kafka Broker 配置中的最大连接数超出限制问题1. 错误原因2. 相关 Kafka 配置参数2.1 connections.max2.2 max.connections.per.ip2.3 num.network.threads2.4 connections.ma…...

编程日记 2026/5/9 21:45:27

SpringBoot开发（二）Spring Boot项目构建、Bootstrap基础知识

1. Spring Boot项目构建 1.1. 简介 基于官方网站https://start.spring.io进行项目的创建. 1.1.1. 简介 Spring Boot是基于Spring4框架开发的全新框架，设计目的是简化搭建及开发过程，并不是对Spring功能上的增强，而是提供了一种快速使用Spr…...

编程日记 2026/5/13 2:13:26

【FISCO BCOS】二十四、通过Java SDK对FISCO BCOS进行压力测试

Java SDK Demo是基于Java SDK的基准测试集合，能够对FISCO BCOS节点进行压力测试。Java SDK Demo提供有合约编译功能，能够将Solidity合约文件转换成Java合约文件，此外还提供了针对转账合约、CRUD合约以及AMOP功能的压力测试示例程序。本篇我们来讲讲使用java SDK压力测试的操…...

编程日记 2026/5/8 20:59:43

【PyTorch】4.张量拼接操作

个人主页：Icomi 在深度学习蓬勃发展的当下，PyTorch 是不可或缺的工具。它作为强大的深度学习框架，为构建和训练神经网络提供了高效且灵活的平台。神经网络作为人工智能的核心技术，能够处理复杂的数据模式。通过 PyTorch&#xff0…...

编程日记 2026/5/10 22:40:09

新电脑安装系统找不到硬盘原因和解决方法来了

有不少网友反馈新电脑采用官方u盘方式装win10或win100出现找不到硬盘是怎么回事？后来研究半天发现是bios中开启了rst(vmd)模式。如果关闭rst模式肯定是可以安装的，但这会影响硬盘性能，有没有办法解决开启rst模式的情况安装win10或win11呢&…...

编程日记 2026/5/12 13:55:34

Python3 【高阶函数】水平考试：30道精选试题和答案

Python3 【高阶函数】水平考试：30道精选试题和答案 试卷说明 本试卷包含：选择题：15 道、填空题：10 道和 编程题：5 道，总分 100 分。每道题后附有答案和解析。 高阶函数测试试卷 满分：100 分 …...

编程日记 2026/3/5 3:28:46

「 机器人 」仿生扑翼飞行器中的“被动旋转机制”概述

前言 在仿生扑翼飞行器的机翼设计中，模仿昆虫翼的被动旋转机制是一项关键技术。其核心思想在于：机翼旋转角度（攻角）并非完全通过主动伺服来控制，而是利用空气动力和惯性力的作用，自然地实现被动调节。以下对这种设计的背景、原理与优势进行详细说明。 1. 背景：昆虫的被动…...

编程日记 2026/5/7 17:19:36

Android GLSurfaceView 覆盖其它控件问题 (RK平台)

平台 涉及主控: RK3566 Android: 11/13 问题 在使用GLSurfaceView播放视频的过程中, 增加了一个播放控制面板, 覆盖在视频上方. 默认隐藏setVisibility(View.INVISIBLE);点击屏幕再显示出来. 然而, 在RK3566上这个简单的功能却无法正常工作. 通过缩小视频窗口可以看到, 实际…...

编程日记 2026/5/12 10:42:15

【C++】类和对象（五）

1、初始化列表 作用&#xff1a;C提供了初始化列表语法&#xff0c;用来初始化属性。 语法&#xff1a; 构造函数&#xff08;&#xff09;&#xff1a;属性1&#xff08;值1&#xff09;&#xff0c;属性2&#xff08;值2&#xff09;...{}示例&#xff1a; #include<i…...

编程日记 2026/5/13 4:18:15

在win11下搭建ios开发环境

就是安装VMware&#xff0c;然后安装mac虚拟机。 主要参考了这一篇&#xff1a;windows上安装macOS系统虚拟机_windows安装macos虚拟机-CSDN博客 还参考了这一篇&#xff1a;【保姆级别教程】VMware虚拟机安装Mac OS15苹果系统附带【VMware TooLS安装】【解锁虚拟机】和【Mac…...

编程日记 2026/5/12 21:44:24

Maven的下载安装配置

maven的下载安装配置 maven是什么 Maven 是一个用于 Java 平台的 自动化构建工具&#xff0c;由 Apache 组织提供。它不仅可以用作包管理&#xff0c;还支持项目的开发、打包、测试及部署等一系列行为 Maven的核心功能 项目构建生命周期管理&#xff1a;Maven定义了项目构建…...

编程日记 2026/5/5 4:24:38

Mysql主从复制+MHA实验笔记[特殊字符]

目录 基本概念 工作原理 优势 环境准备&#xff1a;四台centos-其中三台mysql&#xff0c;一台MHA 配置一主两从 安装MHA 配置无密码认证 配置MHA 模拟master故障 基本概念 MySQL 主从复制&#xff1a;是 MySQL 数据库中实现数据冗余、数据备份和高可用性的重要技术手…...

编程日记 2026/5/11 13:58:32

vue3中自定一个组件并且能够用v-model对自定义组件进行数据的双向绑定

1. 基础用法 在 Vue3 中&#xff0c;v-model 在组件上的使用有了更灵活的方式。默认情况下&#xff0c;v-model 使用 modelValue 作为 prop&#xff0c;update:modelValue 作为事件。 1.1 基本示例 <!-- CustomInput.vue --> <template><input:value"mo…...

编程日记 2026/3/28 8:36:24

面向长文本的多模型协作摘要架构：多LLM文本摘要方法

多LLM摘要框架在每轮对话中包含两个基本步骤:生成和评估。这些步骤在多LLM分散式摘要和集中式摘要中有所不同。在两种策略中,k个不同的LLM都会生成多样化的文本摘要。然而在评估阶段,多LLM集中式摘要方法使用单个LLM来评估摘要并选择最佳摘要,而分散式多LLM摘要则使用k个LLM进行…...

编程日记 2026/5/3 22:49:50

Python中容器类型的数据（上）

若我们想将多个数据打包并且统一管理&#xff0c;应该怎么办? Python内置的数据类型如序列(列表、元组等)、集合和字典等可以容纳多项数据&#xff0c;我们称它们为容器类型的数据。 序列 序列 (sequence) 是一种可迭代的、元素有序的容器类型的数据。 序列包括列表 (list)…...

编程日记 2026/5/13 2:06:12

Spring MVC中HandlerInterceptor和Filter的区别

目录 一、处理阶段 二、功能范围 三、参数访问 四、配置方式 五、使用场景说明 在Spring MVC中&#xff0c;HandlerInterceptor和Filter都是用于拦截请求的重要组件&#xff0c;但它们在多个方面存在显著的差异。本文将详细解析这两种拦截机制的区别&#xff0c;并结合使用…...

编程日记 2026/4/20 4:45:35

[Qt]系统相关-网络编程-TCP、UDP、HTTP协议

目录 前言 一、UDP网络编程 1.Qt项目文件 2.UDP类 QUdpSocket QNetworkDatagram 3.UDP回显服务器案例 细节 服务器设计 客户端设计 二、TCP网络编程 1.TCP类 QTcpServer QTcpSocket 2.TCP回显服务器案例 细节 服务器设计 客户端设计 三、HTTP客户端 1.HTTP…...

编程日记 2026/5/12 14:43:53

wow-agent---task4 MetaGPT初体验

先说坑&#xff1a; 1.使用git clone模式安装metagpt 2.模型尽量使用在线模型或本地高参数模型。 这里使用python3.10.11调试成功 一&#xff0c;安装 安装 | MetaGPT&#xff0c;参考这里的以开发模型进行安装 git clone https://github.com/geekan/MetaGPT.git cd /you…...

编程日记 2026/5/4 0:36:51

信息系统管理工程师第6-8章精讲视频及配套千题通关双双发布，附第14章思维导图

这一周发文少&#xff0c;不是我在偷懒&#xff0c;而是在和信管的视频及千题通关“”浴血奋战 &#xff0c;特别是第8章卡了我很久&#xff0c;因为内容实在太多&#xff0c;精讲视频估计都差不多4个小时了&#xff0c;还好终于在春节前拿下&#xff0c;提供给小分队的同学&am…...

编程日记 2026/4/30 8:49:15

npm启动前端项目时报错（vue) error:0308010C:digital envelope routines::unsupported

vue 启动项目时&#xff0c;npm run serve 报下面的错&#xff1a; error:0308010C:digital envelope routines::unsupported at new Hash (node:internal/crypto/hash:67:19) at Object.createHash (node:crypto:133:10) at FSReqCallback.readFileAfterClose [as on…...

编程日记 2026/5/13 2:08:28

Excel 技巧21 - Excel中整理美化数据实例，Ctrl+T 超级表格(★★★）

本文讲Excel中如何整理美化数据的实例&#xff0c;以及CtrlT 超级表格的常用功能。 目录 1&#xff0c;Excel中整理美化数据 1-1&#xff0c;设置间隔行颜色 1-2&#xff0c;给总销量列设置数据条 1-3&#xff0c;根据总销量设置排序 1-4&#xff0c;加一个销售趋势列 2&…...

编程日记 2026/5/9 0:59:51

力扣算法题——11.盛最多水的容器

目录 &#x1f495;1.题目 &#x1f495;2.解析思路 本题思路总览 借助双指针探索规律 从规律到代码实现的转化 双指针的具体实现 代码整体流程 &#x1f495;3.代码实现 &#x1f495;4.完结 二十七步也能走完逆流河吗 &#x1f495;1.题目 &#x1f495;2.解析思路…...

编程日记 2026/5/12 18:30:55

微服务学习-服务调用组件 OpenFeign 实战

1. OpenFeign 接口方法编写规范 1.1. 在编写 OpenFeign 接口方法时&#xff0c;需要遵循以下规范 1.1.1.1. 接口中的方法必须使用 RequestMapping、GetMapping、PostMapping 等注解声明 HTTP 请求的类型。 1.1.1.2. 方法的参数可以使用 RequestParam、RequestHeader、PathVa…...

编程日记 2026/5/7 8:10:13

PDF2WORD万能方法，如何控制Adobe dc pro，自动实现PDF转word

如何用JavaScript控制Adobe DC Pro来自动实现PDF转Word。首先&#xff0c;我需要考虑Adobe DC Pro是否有公开的API或者扩展接口。我记得Adobe Acrobat Pro DC支持JavaScript&#xff0c;但主要是用于表单处理和文档操作&#xff0c;比如Acrobat JavaScript。不过&#xff0c;自…...

编程日记 2026/5/13 18:13:03

Java Web-Tomcat Servlet

Web服务器-Tomcat Web服务器简介 Web 服务器是一种软件程序&#xff0c;它主要用于在网络上接收和处理客户端&#xff08;如浏览器&#xff09;发送的 HTTP 请求&#xff0c;并返回相应的网页内容或数据。以下是关于 Web 服务器的详细介绍&#xff1a; 功能 接收请求&#…...

编程日记 2026/5/13 18:01:42

寒假学web--day09

简介 一些魔法函数与php反序列化漏洞 tips 反序列化和类的方法无关&#xff0c;不能把类的方法序列化 将php.exe所在目录放到环境变量中&#xff0c;就可以在终端里通过php.exe ./命令来执行php代码 魔术方法 __construct() 在实例化一个对象时会自动调用&#xff0c;可…...

编程日记 2026/5/11 13:23:56

深度解析：基于Vue 3的教育管理系统架构设计与优化实践

一、项目架构分析 1. 技术栈全景 项目采用 Vue 3 TypeScript Tailwind CSS 技术组合&#xff0c;体现了现代前端开发的三大趋势&#xff1a; 响应式编程&#xff1a;通过Vue 3的Composition API实现细粒度响应 类型安全&#xff1a;约60%的组件采用TypeScript编写 原子化…...

编程日记 2026/5/12 22:12:28

CNN-BiLSTM卷积双向长短期记忆神经网络时间序列预测（Matlab完整源码和数据）

CNN-BiLSTM卷积双向长短期记忆神经网络时间序列预测&#xff08;Matlab完整源码和数据&#xff09; 目录 CNN-BiLSTM卷积双向长短期记忆神经网络时间序列预测&#xff08;Matlab完整源码和数据&#xff09;预测效果基本介绍 CNN-BiLSTM卷积双向长短期记忆神经网络时间序列预测一…...

编程日记 2026/5/12 20:24:22

mysql_store_result的概念和使用案例

mysql_store_result() 是 MySQL C API 中的一个函数&#xff0c;用于检索一个完整的结果集到一个客户端。当执行一个查询&#xff08;通常是 SELECT 查询&#xff09;并希望处理所有返回的数据时&#xff0c;可以使用此函数。 概念 mysql_store_result() 函数的原型如下&…...

编程日记 2026/3/2 22:24:16

docker安装MySQL8:docker离线安装MySQL、docker在线安装MySQL、MySQL镜像下载、MySQL配置、MySQL命令

一、镜像下载 1、在线下载 在一台能连外网的linux上执行docker镜像拉取命令 docker pull mysql:8.0.41 2、离线包下载 两种方式&#xff1a; 方式一&#xff1a; -&#xff09;在一台能连外网的linux上安装docker执行第一步的命令下载镜像 -&#xff09;导出 # 导出镜…...

编程日记 2026/5/6 1:00:43