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

Nginx + Kafka 可编程精细控制完整版（可直接落地运行）

news 2026/5/16 8:35:49

一、Nginx 可编程动态管控（不用改配置文件，代码控制）

核心原理

Nginx 支持信号重载 + 动态 upstream + 配置热加载，通过nginx -s信号 + Lua/API 实现不停机改负载、切流量、拉黑 IP。

1. 系统信号控制（Shell / 代码可调用）

bash

运行

# 平滑重启（不中断连接） nginx -s reload # 快速停止 nginx -s stop # 优雅退出 nginx -s quit # 重新打开日志 nginx -s reopen

2. Python 调用 Nginx 控制（编程化）

python

运行

import subprocess def nginx_reload(): # 平滑重载配置 subprocess.run(["nginx", "-s", "reload"], check=True) def nginx_stop(): subprocess.run(["nginx", "-s", "stop"], check=True) # 调用 nginx_reload()

3. Nginx 动态负载均衡（Lua 可编程改后端节点）

安装lua-nginx-module后，可代码动态增删后端服务、调权重、灰度流量，无需改.conf 文件。适用场景：线上扩容、故障摘除、AB 测试。

二、Kafka 可编程精细管控（Java + Python 双版本）

核心管控能力

创建 / 删除 Topic、修改分区副本、重置消费位点、查看集群元数据、限流、监控积压。

1. Python 版可直接运行

安装依赖：

bash

运行

pip install kafka-python kafka-admin

python

运行

from kafka.admin import KafkaAdminClient, NewTopic # 连接kafka admin_client = KafkaAdminClient( bootstrap_servers="127.0.0.1:9092" ) # 1. 创建Topic topic = NewTopic( name="test_order_topic", num_partitions=4, replication_factor=1 ) admin_client.create_topics([topic]) # 2. 查看所有Topic print(admin_client.list_topics()) # 3. 删除Topic # admin_client.delete_topics(["test_order_topic"]) # 关闭连接 admin_client.close()

2. Java Kafka 运维管控（企业常用）

Maven 依赖

xml

<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.2.0</version> </dependency>

核心代码

java

运行

import org.apache.kafka.clients.admin.AdminClient; import org.apache.kafka.clients.admin.AdminClientConfig; import org.apache.kafka.clients.admin.NewTopic; import java.util.Properties; public class KafkaAdminDemo { public static void main(String[] args) { Properties props = new Properties(); props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1:9092"); AdminClient adminClient = AdminClient.create(props); // 创建Topic：分区6，副本1 NewTopic newTopic = new NewTopic("pay_topic", 6, (short) 1); adminClient.createTopics(java.util.Collections.singletonList(newTopic)); // 关闭 adminClient.close(); } }