洪水灾害多智能体分布式模拟示例代码
1. 环境定义：支持灾害动态、地理数据和分布式架构
import numpy as np
import random
import matplotlib.pyplot as plt# 新疆主要城市及邻接关系
XINJIANG_CITIES = {'Urumqi': ['Changji', 'Shihezi'],'Changji': ['Urumqi', 'Shihezi', 'Turpan'],'Shihezi': ['Urumqi', 'Changji', 'Karamay'],'Karamay': ['Shihezi'],'Turpan': ['Changji']
}CITY_COORDINATES = {'Urumqi': (43.8256, 87.6168),'Changji': (44.0169, 87.3082),'Shihezi': (44.3024, 86.0369),'Karamay': (45.5798, 84.8892),'Turpan': (42.9513, 89.1895)
}class XinjiangFloodEnvironment:def __init__(self, cities, max_steps=50, disaster_spread_prob=0.3):"""新疆多城市洪水灾害环境。参数:- cities: 城市及邻接关系字典。- max_steps: 每回合最大步数。- disaster_spread_prob: 灾害扩散概率。"""self.cities = citiesself.city_list = list(cities.keys())self.num_cities = len(self.city_list)self.max_steps = max_stepsself.disaster_spread_prob = disaster_spread_probself.reset()def reset(self):""" 重置环境，初始化灾害和资源分布。 """self.steps = 0self.disaster_status = {city: 0 for city in self.city_list} # 灾害状态：0为无灾，1为灾害中self.resource_status = {city: 5 for city in self.city_list} # 每城市初始资源disaster_city = random.choice(self.city_list)self.disaster_status[disaster_city] = 1 # 随机选择灾害城市return self._get_state()def _get_state(self):""" 获取当前状态，包含灾害和资源信息。 """return {'disaster_status': self.disaster_status,'resource_status': self.resource_status}def _spread_disaster(self):""" 模拟灾害扩散。 """new_disaster_status = self.disaster_status.copy()for city, status in self.disaster_status.items():if status == 1: # 当前城市有灾害for neighbor in self.cities[city]:if random.random() < self.disaster_spread_prob:new_disaster_status[neighbor] = 1self.disaster_status = new_disaster_statusdef step(self, actions):"""执行动作。参数:- actions: 每个城市的动作字典 {city: allocated_resources}。返回:- 下一状态- 总奖励- 是否结束"""total_reward = 0for city, allocated_resources in actions.items():if self.disaster_status[city] == 1: # 如果该城市有灾害if allocated_resources > 0:self.resource_status[city] -= allocated_resourcesif self.resource_status[city] < 0: # 资源不能为负allocated_resources += self.resource_status[city]self.resource_status[city] = 0self.disaster_status[city] = 0 # 灾害解决total_reward += 10 # 成功解决灾害else:total_reward -= 5 # 未响应灾害的惩罚self.steps += 1if self.steps >= self.max_steps or sum(self.disaster_status.values()) == 0:return self._get_state(), total_reward, True # 所有灾害解决或步数结束# 更新灾害状态（灾害扩散）self._spread_disaster()return self._get_state(), total_reward, False # 继续运行def render(self):""" 可视化当前环境状态。 """disaster_cities = [city for city, status in self.disaster_status.items() if status == 1]print(f"Step {self.steps}:")print(f"Disaster Cities: {disaster_cities}")print(f"Resource Status: {self.resource_status}")plt.figure(figsize=(8, 8))for city, (lat, lon) in CITY_COORDINATES.items():plt.scatter(lon, lat, color='blue' if city in self.resource_status else 'red', s=100)plt.text(lon, lat, city, fontsize=10)plt.xlabel("Longitude")plt.ylabel("Latitude")plt.title("Xinjiang Flood Simulation")plt.show()
2. 分布式多智能体实现
class DistributedAgent:def __init__(self, city, action_size):"""分布式智能体。参数:- city: 智能体负责的城市。- action_size: 动作空间大小。"""self.city = cityself.action_size = action_sizeself.epsilon = 1.0 # 探索概率self.epsilon_decay = 0.995self.epsilon_min = 0.01def act(self, state, available_resources):""" 基于当前状态和资源选择动作。 """if np.random.rand() <= self.epsilon:return random.randint(0, available_resources) # 随机分配资源return available_resources # 简化决策：全分配def update_epsilon(self):""" 衰减探索概率。 """if self.epsilon > self.epsilon_min:self.epsilon *= self.epsilon_decay
3. 动态奖励函数
def calculate_reward(disaster_map, response_time, resources_used, weights):"""计算动态奖励。参数:- disaster_map: 当前灾害状态。- response_time: 当前响应时间。- resources_used: 当前使用的资源量。- weights: 奖励函数的权重 (dict)。返回:- reward: 总奖励值。"""covered_disasters = disaster_map.sum() # 未解决的灾害数量return (weights['covered'] * (1 - covered_disasters) -weights['time'] * response_time -weights['resources'] * resources_used)
4. 主训练循环
if __name__ == "__main__":env = XinjiangFloodEnvironment(XINJIANG_CITIES) # 初始化环境agents = {city: DistributedAgent(city, 5) for city in XINJIANG_CITIES.keys()} # 每城市一个智能体episodes = 100 # 训练轮次for e in range(episodes):state = env.reset() # 重置环境total_reward = 0while True:actions = {}for city, agent in agents.items():available_resources = state['resource_status'][city]actions[city] = agent.act(state, available_resources) # 每个智能体选择动作next_state, reward, done = env.step(actions) # 执行动作total_reward += rewardif done:print(f"Episode {e+1}/{episodes}, Total Reward: {total_reward}")env.render()breakstate = next_state# 更新每个智能体的探索概率for agent in agents.values():agent.update_epsilon()
功能扩展与总结
-
灾害动态扩展：
- 灾害通过邻接城市扩散。
- 动态更新灾害状态，提升模拟真实性。
-
多智能体分布式协作：
- 每个智能体管理自己城市的资源。
- 集中式奖励计算与全局决策评估。
-
动态奖励函数：
- 同时优化响应时间、资源成本和覆盖范围。
-
新疆地理数据支持：
- 模拟新疆主要城市及其邻接关系。
- 地理坐标可视化，帮助分析决策动态。
相关文章：
洪水灾害多智能体分布式模拟示例代码
1. 环境定义：支持灾害动态、地理数据和分布式架构 import numpy as np import random import matplotlib.pyplot as plt# 新疆主要城市及邻接关系 XINJIANG_CITIES {Urumqi: [Changji, Shihezi],Changji: [Urumqi, Shihezi, Turpan],Shihezi: [Urumqi, Changji, K…...
基于 Ragflow 搭建知识库-初步实践
基于 Ragflow 搭建知识库-初步实践 一、简介 Ragflow 是一个强大的工具，可用于构建知识库，实现高效的知识检索和查询功能。本文介绍如何利用 Ragflow 搭建知识库，包括环境准备、安装步骤、配置过程以及基本使用方法。 二、环境准备 硬件要…...
Selenium实践总结
1.使用显示等待而不是隐式等待 隐式等待可能会导致不可预测的测试行为，尤其是在动态 Web 应用程序中。显式等待，它允许您 等待特定条件发生后再继续测试，这种方法提供了更多的控制和可靠性。 WebDriverWait wait new WebDriverWait(drive…...
termux记录 使用ddns-go，alist)
华为麦芒5(安卓6)termux记录 使用ddns-go，alist
下载0.119bate1 安卓5和6版本,不能换源,其他源似乎都用不了,如果root可以直接用面具模块 https://github.com/termux/termux-app/releases/download/v0.119.0-beta.1/termux-app_v0.119.0-beta.1apt-android-5-github-debug_arm64-v8a.apk 安装ssh(非必要) pkg install open…...
Springboot jar包加密加固并进行机器绑定
获取机器码，通过classfinal-fatjar-1.2.1.jar来获取机器码 命令：java -jar classfinal-fatjar-1.2.1.jar -C 对springboot打包的jar进行加密功能 java -jar classfinal-fatjar-1.2.1.jar -file lakers-ljxny-3.0.0.jar -packages com.lygmanager.laker…...
【Microi吾码】开源力量赋能低代码创新，重塑软件开发生态格局
我的个人主页 文章专栏：Microi吾码 一、引言 在当今数字化浪潮汹涌澎湃的时代，软件开发的需求呈现出爆发式增长。企业为了在激烈的市场竞争中脱颖而出，不断寻求创新的解决方案以加速数字化转型。传统的软件开发方式往往面临着开发周期长、技…...
系统思考—冰山模型
“卓越不是因机遇而生，而是智慧的选择与用心的承诺。”—— 亚里士多德 卓越，从来不是一次性行为，而是一种习惯。正如我们在日常辅导中常提醒自己：行为的背后，隐藏着选择的逻辑，而选择的根源，源…...
Java读取InfluxDB数据库的方法
本文介绍基于Java语言，读取InfluxDB数据库的方法，包括读取InfluxDB的所有数据库，以及指定数据库中的measurement、field、tag等。 首先，创建一个Java项目，用于撰写代码。如果大家是基于IDEA来创建项目，则可…...
【mybatis-plus问题集锦系列】在mybatisplus中无法autowired的原因排查及解决
mybatisplus简化了我们做数据操作，大大提升了我们的开发速度，但是今天在做测试的时候，突然报了这么个错误，排查好久才找到解决方案，特此记录下 问题复现 这里的测试方法报错，通过不了测试 org.springf…...
python中Windows系统使用 pywin32 来复制图像到剪贴板，并使用 Selenium 模拟 Ctrl+V 操作
步骤 1：安装必要的库 首先，安装 pywin32 和 selenium： pip install pywin32 selenium 如果使用的是 macOS，可以安装 pyobjc： pip install pyobjc 步骤 2：使用 pywin32 复制图像到剪贴板 在 Windows 系统中…...
uniapp——微信小程序，从客户端会话选择文件
微信小程序选择文件 文章目录 微信小程序选择文件效果图选择文件返回数据格式 API文档： chooseMessageFile 微信小程序读取文件，请查看 效果图 选择文件 /*** description 从客户端会话选择文件* returns {String} 文件路径*/ const chooseFile () &g…...
点亮核心板小灯 STM32U575
将核心板上的运行状态指示灯点亮 任务分析 灯如何点亮 如何看开发板原理图 开发板上的灯硬件组成 原理图 原理图（Schematic Diagram），也称为电路图或电气图，是一种图形表示方法，用于展示电子系统或电路的工作原理和…...
“图书馆服务自动化”：基于SSM框架的图书借阅系统开发
3.1系统的需求分析 需求分析阶段是设计系统功能模块的总方向，可以这样来说，系统的整个的开发流程以及设计进度，基本上都是以需求分析为基本依据的[10]。需求分析阶段可以确定系统的基本功能设计，以及在最后的系统验收阶段…...
)
顶顶通呼叫中心中间件的三种呼叫方式(mod_cti基于FreeSWITCH)
顶顶通呼叫中心共有三种呼叫方式： 手拨呼叫点击呼叫自动外呼 联系我们 有意向了解呼叫中心中间件的用户，可以点击该链接添加工作人员：https://blog.csdn.net/H4_9Y/article/details/136148229 手拨呼叫 手拨呼叫属于常规的呼叫方式&…...
HCIA笔记9--NAT、ACL与链路聚合
1. ACL ACL: 访问控制列表, Access Control List。 通过定义规则来允许或拒绝流量的通过。 1.1 ACL分类 1.2 配置实例 如图所示，对R2的访问只允许192.168.1.0/24网段。 我们可以配置基本acl来限制 acl 2000 acl number 2000 rule 5 permit source 192.168.1.0 0…...
【笔记】在虚拟机中通过apache2给一个主机上配置多个web服务器
（配置出来的web服务器又叫虚拟主机……） 下载apache2 sudo apt update sudo apt install apache2 （一）ip相同 web端口不同的web服务器 进入 /var/www/html 创建站点一和站点二的目录文件（目录文件名自定义哈&#x…...
“校园健康数据管理”：疫情管控系统的信息收集与分析
3.1可行性分析 通过对系统实行的目的初步调查和分析，提出可行性方案并对其一一进行论证。我们在这里主要从技术可行性、经济可行性、操作可行性等方面进行分析。 3.1.1 技术可行性 1.硬件可行性分析 校园疫情管控系统系统的硬件要求方面不存在特殊的要求，…...
MySQL 中存储金额数据一般使用什么数据类型
在 MySQL 中存储金额数据时，应该谨慎选择数据类型，以确保数据的精度和安全性。以下是几种常用的数据类型及其适用性： DECIMAL 类型： 描述：DECIMAL 类型是专门为存储精确的小数而设计的。它可以指定小数点前后的数字位数…...
使用 .NET 6 或 .NET 8 上传大文件
如果您正在使用 .NET 6，并且它拒绝上传大文件，那么本文适合您。 我分享了一些处理大文件时需要牢记的建议，以及如何根据我们的需求配置我们的服务，并提供无限制的服务。 本文与 https://blog.csdn.net/hefeng_aspnet/arti…...
帝国cms电脑pc站url跳转到手机站url的方法
本文讲解一下帝国cms电脑网站跳转到手机动态网站和手机静态网站的方法,笔者以古诗词网 www.gushichi.com为例，为大家介绍操作步骤。方法一：帝国pc站跳转到手机静态站 1、假设我们有帝国cms 电脑网站www.XXX.com，手机网站m.XXX.com …...
D类音频应用EMI管理
1、前言 对于EMI，首先需要理解天线。频率和波长之间的关系，如下图所示。 作为有效天线所需的最短长度是λ/4。在空气中，介电常数是1，但是在FR4或玻璃环氧PCB的情况下，介电常数大约4.8。这种效应会导致信号在FR4材…...
【行业发展报告】2024大数据与智能化行业发展浅析
回首 2024，大数据智能化浪潮汹涌。海量数据宛如繁星，在智能算法的苍穹下汇聚、碰撞，释放出洞察市场与用户的强大能量，精准勾勒出商业新航线。我们精心雕琢技术架构，从数据存储的坚固基石到处理分析的高效引擎ÿ…...
--使用IDEA开发Scala)
闲谭Scala(3)--使用IDEA开发Scala
1. 背景 广阔天地、大有作为的青年，怎么可能仅仅满足于命令行。 高端大气集成开发环境IDEA必须顶上，提高学习、工作效率。 开整。 2. 步骤 2.1 创建工程 打开IDEA，依次File-New-Project…，不好意思我的是中文版：…...
系统压力测试助手——stress-ng
1、背景 在系统性能测试和压力测试中，stress-ng 是一个非常强大的工具，广泛应用于对 Linux 系统进行各种硬件和软件方面的负载测试。它能够模拟多种极端负载情况，帮助开发人员和运维人员检查系统在高负载下的表现，以便发现潜在的…...
FFmpeg推拉流命令
命令简介 它可以将本地的视频/音频流推送到服务器，也可以将服务器上的音视频流拉到本地。 推流命令的命令格式 ffmpeg -re -i [输入文件] -c:v [视频编码器] -c:a [音频编码器] -f [输出格式] [推流地址] 参数解析 -re 表示采用实时模式，以原始速度…...
【Spring】基于注解的Spring容器配置—— @Component及其衍生注解
Spring框架因其灵活性和强大的功能被广泛应用于企业级应用的开发中。Spring提供了一种基于IoC（控制反转）和AOP（面向切面编程）的编程模型，使得开发者能够以更简单和高效的方式管理应用程序的对象及其依赖关系。 在Spri…...
基于统计分析与随机森林的环境条件对生菜生长的影响研究
1.项目背景 随着现代农业的发展，对植物生长过程中环境因素的影响有了越来越多的关注，基于2023年8月3日至2023年9月19日期间记录的70个不同生菜样本的生长数据进行分析，可以更好地理解温度、湿度、pH值和总溶解固体（TDS࿰…...
基于PyQt5的UI界面开发——多界面切换
介绍 最初，因为课设的缘故，我只是想做一个通过按键进行切面切换而已，但是我看网上资料里面仅是语焉不详，让我困惑的很，但后面我通过摸索才发现这件事实在是太简单了，因此我想要记录下来。 本博客将介绍如…...
C语言-结构体内存大小
#include <stdio.h> #include <string.h> struct S1 { char a;//1 int b;//4 char c;//1 }; //分析 默认对齐数 成员对齐数 对齐数(前两个最小值) 最大对齐数 // 8 1 …...
搭建vue项目
一、环境准备 1、安装node node官网：https://nodejs.org/zh-cn 1.1、打开官网，选择“下载”。 1.2、选择版本号，选择系统，根据需要自行选择，上面是命令安装方式，下载是下载安装包。 1.3、检查node安装…...
【每日学点鸿蒙知识】Text填充父控件、Native接收数组、js逻辑不执行问题、UIAbility上下文问题、页面跳转路由栈
1、HarmonyOS 如何使Text组件填充满父组件？ build() {Row() {Row() {Text(this.str).constraintSize({ maxWidth: 100%, minHeight: "30vp" }).backgroundColor(Color.Gray).fontSize(24vp)}.key(row1).constraintSize({ maxWidth: 100%}).backgroundCol…...
Debian-linux运维-ssh配置（兼容Jenkins插件的ssh连接公钥类型）
系统版本：Debian 12.5、11.1 1 生成密钥对 可以用云服务商控制台生成的密钥对，也可以自己在客户端或者服务器上生成， 已经有密钥对就可以跳过这步 用户默认密钥文件路径为 ~/.ssh/id_rsa，可以在交互中指定路径，也可…...
37. socketserver模块
一、socketserver模块 SocketServer 是标准库中的一个高级模块，它的目标是简化很多样板代码，它们是创建网络客户端和服务器所必须的代码。这个模块中有为你创建的各种各样的类。 类描述BaseServer包含核心服务器功能和 min-in 类的钩子；仅用…...
【详细讲解】hive优化
1、开启本地模式 大多数的Hadoop Job是需要Hadoop提供的完整的可扩展性来处理大数据集的。不过，有时Hive的输入数据量是非常小的。在这种情况下，为查询触发执行任务消耗的时间可能会比实际job的执行时间要多的多。对于大多数这种情况，Hive可…...
芝法酱学习笔记（2.3）——shardingsphere分库分表
一、前言 之前的例子中，我们以一个简化了的销售单报表查询，展示了大数据量查询时，在索引和变量类型层面可以做的一些优化。可我们发现，无论怎么优化，一次查询都要好几秒。 这是一个现实问题，只要一个系统用…...
【超简单】Python入门实用教程
Python 入门教程 1 ---- Python Syntax Python是一个高效的语言，读和写的操作都是很简单的，就像普通的英语一样 Python是一个解释执行的语言，我们不需要去编译，我们只要写出代码即可运行 Python是一个面向对象的语言，…...
c语言中void关键字的含义和用法
在 C 语言中，void 是一个特殊的关键字，主要有以下几个用途： 1. 表示函数没有返回值 当一个函数不需要返回任何值时，可以将其返回类型声明为 void。 #include <stdio.h>void printMessage() {printf("Hello, World!\…...
数据库课程设计-工资管理系统-MySQL
目录 第一节 需求分析 1.1 需求分析概述 1.2 功能需求分析 1.2.1 人事数据管理模块 1.2.2 考勤数据管理模块 1.2.3 工资数据管理模块 1.2.4 工资计算公式设置模块 1.3 数据需求分析 1.3.1 数据项定义 1.3.2 数据结构定义 第二节 概念结构设计 2.1 分E-R图 ?2.2 基…...
基于 DINOv2 模型实现图搜图相似度检索任务
一、DINOv2 模型简介及使用 DINOv2是由Meta AI开发的第二代自监督视觉变换器模型，采用 Vision Transformer (ViT) 架构 。其核心特点是在无需人工标签的情况下，通过自监督学习技术，从海量无标注图像中学习有意义的视觉特征表示，类…...
Excel将混乱的多行做成1列
目标是将数据按从左到右，再从上到下排成一列。 公式法 首先用textjoin函数将文本包起来，做成一个超长文本。 然后用公式 截取文本 Mid(m1,n,3)，意思就是对m1单元格，从第n个字符开始，截取3个字符出来。 这个公式如何自…...
2021.12.28基于UDP同信的相关流程
作业 1、将TCP的CS模型再敲一遍 服务器 #include <myhead.h> #define PORT 8888 #define IP "192.168.124.123" int main(int argc, const char *argv[]) {//创建套接字//绑定本机IP和端口号//监听客户端请求//接收客户端连接请求//收发消息//创建套接字int…...
DevOps工程技术价值流：Ansible自动化与Semaphore集成
在DevOps的浪潮中，自动化运维工具扮演着举足轻重的角色。Ansible，作为一款新兴的自动化运维工具，凭借其强大的功能和灵活性，在运维领域迅速崭露头角。本文将深入探讨Ansible的特点、架构、工作原理，以及其应用场景&…...
【 Git 设置代理】
【 Git 设置代理】 1. 设置代理2. 检查当前 Git 代理3. 测试代理是否正常4. 查看Git所有配置5. 取消添加的代理 1. 设置代理 添加 HTTP 和 HTTPS 代理： git config --global http.proxy http://127.0.0.1:10809 git config --global https.proxy http://127.0.0.1…...
使用 HTML 和 CSS 实现绚丽的节日烟花效果
文章目录 1. 效果预览2. 核心技术栈3. 核心代码解读3.1 HTML结构3.2 霓虹文字的CSS样式3.2.1 核心样式代码3.2.2 动画效果 3.3 JavaScript 的烟花效果实现3.3.1 烟花上升3.3.2 粒子爆炸 4. 用户交互5. 运行步骤总结 1. 效果预览 打开后输入文本的展示内容 用户点击页面后播放…...
Java - 日志体系_Apache Commons Logging（JCL）日志接口库_适配Log4j2 及 源码分析
文章目录 PreApache CommonsApache Commons ProperLogging （Apache Commons Logging ） JCL 集成Log4j2添加 Maven 依赖配置 Log4j2验证集成 源码分析1. Log4j-jcl 的背景2. log4j-jcl 的工作原理2.1 替换默认的 LogFactoryImpl2.2 LogFactoryImpl 的实现…...
【Halcon】例程讲解：基于形状匹配与OCR的多图像处理（附图像、程序下载链接）
1. 开发需求 在参考图像中定义感兴趣区域（ROI），用于形状匹配和文本识别。通过形状匹配找到图像中的目标对象位置。对齐多幅输入图像，使其与参考图像保持一致。在对齐后的图像上进行OCR识别，提取文本和数字信息。以循环…...
FreePBX修改IP地址和端口以及添加SSL证书开启HTTPS访问
最近给单位部署了freepbx网络电话系统，我的系统是安装在ibm x3650 m4物理机上的，iso镜像下载后直接用Rufus烧录到U盘，服务器上先做好了raid1，插上U盘重启服务器开撸。安装过程略过了，在虚拟机上安装就不用那么麻烦。 …...
简易共享屏幕工具改进版
昨天心血来潮写了一篇关于简易共享屏幕工具的文章，发现也有一些阅读量，并且我对于它的效果不是很满意 ，实际呈现的帧率还是太低了。所以我今天换了更高效的方式来实现。 50 行代码简易屏幕共享工具 改进 降低分辨率 昨天那个测试的帧率低&a…...
【WSL】Ubuntu 24.04 安装配置docker
继上一篇文章：【WSL】Ubuntu 22.04 安装配置docker 这次我在新搭建的台式机安装的WSL上，也安装一个docker，因为最近要开发TTS相关的东西。 参考 清华大学镜像站的这篇文章基本涵盖了所有的操作步骤，照着做就行了：Do…...
bash 中 ${-#*i} 是什么意思?
-------------------------------------------------- author: hjjdebug date: 2024年 12月 25日 星期三 17:43:45 CST description: bash 中 ${-#*i} 是什么意思? -------------------------------------------------- 在centos 的 /etc/profile 中有这样的语句 for i in /…...