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

封装 RabbitMQ 消息代理交互的功能

封装了与 RabbitMQ 消息代理交互的功能,包括发送和接收消息,以及管理连接和通道。

主要组件

  1. 依赖项

    • 代码使用了多个命名空间,包括 Microsoft.Extensions.Configuration(用于配置管理)、RabbitMQ.Client(用于与 RabbitMQ 的交互)、Newtonsoft.Json(用于 JSON 序列化和反序列化)。
    • 还使用了一些自定义命名空间,可能是更大应用程序框架的一部分(例如 MSEBP.Kernel.Common)。
  2. 配置模型

    • RabbitConfigModel 用于保存连接 RabbitMQ 的配置设置,包括 IPPortUserNamePasswordVirtualHost 等属性。
  3. 连接管理

    • 类中维护了一个静态字段 _connection 用于 RabbitMQ 连接,并提供了 GetConnection 方法来建立或获取该连接。
    • 连接使用 IP、端口、用户名、密码和虚拟主机等参数进行建立。
  4. 接收消息

    • Receive<T> 方法允许从 RabbitMQ 队列异步消费消息。
    • 使用 EventingBasicConsumer 来处理传入的消息,并通过提供的委托(receiveMethod)进行处理。
    • 消息处理包括错误处理,根据处理是否成功来确认(或否定确认)消息。
  5. 发送消息

    • Send<T> 方法将对象序列化为 JSON,并将其作为消息发送到指定的 RabbitMQ 队列。
    • 此方法允许指定消息是否应为持久化,并为消息设置适当的属性(如头信息)。
  6. 通道管理

    • CreateConsumerChannel 方法创建一个新的通道以与 RabbitMQ 进行交互。
    • 通道用于发送和接收消息,必须从已建立的连接中创建。
  7. 连接工厂

    • GetConnection 方法是一个静态方法,使用 ConnectionFactory 创建新的 RabbitMQ 连接。它配置了心跳和其他参数。
  8. 资源管理

    • Dispose 方法确保在不再需要时正确关闭 RabbitMQ 连接。

错误处理和重试机制

  • 消息消费逻辑中包含错误处理机制,以决定如何处理失败的消息处理:
    • 确认(BasicAck):在成功处理消息时调用。
    • 否定确认(BasicNack):允许根据情况(例如瞬态错误与永久错误)重试消息或拒绝消息
      using Microsoft.Extensions.Configuration;
      using Newtonsoft.Json;
      using RabbitMQ.Client;
      using RabbitMQ.Client.Events;
      using System;
      using System.Collections.Generic;
      using System.Text;
      using System.Threading;
      using System.Threading.Tasks;namespace MSEBP.External.RabbitMQMsg
      {/// <summary>/// 接受消息的服务 /// </summary>public class RabbitMessageService : IDisposable{private readonly RabbitConfigModel _rabbitConfig;private static IConnection _connection;private readonly IConfiguration _configuration;private readonly ILogger _logger;private readonly object _connectionLock = new object();private const int ReconnectDelaySeconds = 5;public RabbitMessageService(IConfiguration configuration){_configuration = configuration;_logger = MSEApplication.Resolve<ILogger>("CorrelationId");_rabbitConfig = LoadConfig();ValidateConfig(_rabbitConfig);}private RabbitConfigModel LoadConfig(){return new RabbitConfigModel{IP = _configuration["RabbitMQ:IP"],Port = _configuration["RabbitMQ:Port"].AsInt(5672),UserName = _configuration["RabbitMQ:UserName"],Password = _configuration["RabbitMQ:Password"],VirtualHost = _configuration["RabbitMQ:VirtualHost"],DurableQueue = _configuration["RabbitMQ:DurableQueue"].AsBool(),QueueName = _configuration["RabbitMQ:QueueName"],Exchange = _configuration["RabbitMQ:Exchange"],ExchangeType = _configuration["RabbitMQ:ExchangeType"],DurableMessage = _configuration["RabbitMQ:DurableMessage"].AsBool(),RoutingKey = _configuration["RabbitMQ:RoutingKey"],};}private void ValidateConfig(RabbitConfigModel config){if (string.IsNullOrWhiteSpace(config.IP) || config.Port <= 0 || string.IsNullOrWhiteSpace(config.UserName) || string.IsNullOrWhiteSpace(config.Password)){throw new InvalidOperationException("RabbitMQ configuration is invalid.");}}public IConnection GetConnection(string clientProvidedName){if (_connection == null || !_connection.IsOpen){lock (_connectionLock){if (_connection == null || !_connection.IsOpen){_connection = CreateConnection(clientProvidedName);}}}return _connection;}private IConnection CreateConnection(string clientProvidedName){var factory = new ConnectionFactory{ClientProvidedName = clientProvidedName,Endpoint = new AmqpTcpEndpoint(new Uri($"amqp://{_rabbitConfig.IP}/")),Port = _rabbitConfig.Port,UserName = _rabbitConfig.UserName,Password = _rabbitConfig.Password,VirtualHost = _rabbitConfig.VirtualHost,RequestedHeartbeat = TimeSpan.FromSeconds(60)};while (true){try{var connection = factory.CreateConnection();connection.ConnectionShutdown += OnConnectionShutdown;_logger.Info("RabbitMQ connection established.");return connection;}catch (Exception ex){_logger.Error("Failed to create RabbitMQ connection, retrying...", ex);Thread.Sleep(TimeSpan.FromSeconds(ReconnectDelaySeconds)); // 等待5秒后重试}}}private void OnConnectionShutdown(object sender, ShutdownEventArgs e){_logger.Warn("RabbitMQ connection was shut down. Attempting to reconnect...");Reconnect();}private void Reconnect(){lock (_connectionLock){if (_connection != null && !_connection.IsOpen){_logger.Info("Disposing of RabbitMQ connection.");_connection.Dispose();_connection = null;}// 重新建立连接_connection = CreateConnection("Reconnect");}}public async Task Receive<T>(Func<T, Task> receiveMethod, CancellationToken cancellationToken){using (var channel = CreateConsumerChannel("Receive")){try{SetupQueue(channel);var consumer = new EventingBasicConsumer(channel);consumer.Received += async (model, ea) => await ProcessMessage(channel, ea, receiveMethod, cancellationToken);channel.BasicConsume(_rabbitConfig.QueueName, false, consumer);// Wait for cancellationawait Task.Delay(Timeout.Infinite, cancellationToken);}catch (OperationCanceledException){_logger.Info("Message consumption was canceled.");}catch (Exception ex){_logger.Error("Failed to set up message consumer", ex);throw;}}}private void SetupQueue(IModel channel){if (!string.IsNullOrWhiteSpace(_rabbitConfig.Exchange)){channel.ExchangeDeclare(_rabbitConfig.Exchange, _rabbitConfig.ExchangeType.ToString(), _rabbitConfig.DurableQueue);channel.QueueDeclare(_rabbitConfig.QueueName, _rabbitConfig.DurableQueue, false, false, null);channel.QueueBind(_rabbitConfig.QueueName, _rabbitConfig.Exchange, _rabbitConfig.RoutingKey);}else{channel.QueueDeclare(_rabbitConfig.QueueName, _rabbitConfig.DurableQueue, false, false, null);}channel.BasicQos(0, 1, false);}private async Task ProcessMessage<T>(IModel channel, BasicDeliverEventArgs ea, Func<T, Task> receiveMethod, CancellationToken cancellationToken){var deliveryTag = ea.DeliveryTag;var message = Encoding.UTF8.GetString(ea.Body.ToArray());try{_logger.Info($"Received message: {message}");var data = JsonConvert.DeserializeObject<T>(message);await receiveMethod(data);channel.BasicAck(deliveryTag, false); // 确认处理成功}catch (Exception ex){_logger.Error($"Error processing message: {message}", ex);channel.BasicNack(deliveryTag, false, true); // 允许重新处理}}public bool Send<T>(T info){var message = JsonConvert.SerializeObject(info);if (string.IsNullOrWhiteSpace(message)) return false;try{using (var channel = CreateConsumerChannel("Send")){SetupSendChannel(channel);var properties = CreateMessageProperties(channel);var bytes = Encoding.UTF8.GetBytes(message);if (string.IsNullOrWhiteSpace(_rabbitConfig.Exchange)){channel.BasicPublish("", _rabbitConfig.QueueName, properties, bytes);}else{channel.BasicPublish(_rabbitConfig.Exchange, _rabbitConfig.RoutingKey, properties, bytes);}}return true;}catch (Exception ex){_logger.Error("Failed to send message to RabbitMQ", ex);return false;}}private void SetupSendChannel(IModel channel){if (!string.IsNullOrWhiteSpace(_rabbitConfig.Exchange)){channel.ExchangeDeclare(_rabbitConfig.Exchange, _rabbitConfig.ExchangeType.ToString(), _rabbitConfig.DurableQueue, false, null);}else{channel.QueueDeclare(_rabbitConfig.QueueName, _rabbitConfig.DurableQueue, false, false, null);}}private IBasicProperties CreateMessageProperties(IModel channel){var properties = channel.CreateBasicProperties();properties.DeliveryMode = Convert.ToByte(_rabbitConfig.DurableMessage ? 2 : 1);properties.Headers = new Dictionary<string, object>{{ "Content-Type", "application/json" },{ "__TypeId__", _rabbitConfig.QueueName }};return properties;}public IModel CreateConsumerChannel(string clientProvidedName){return GetConnection(clientProvidedName).CreateModel();}public void Dispose(){if (_connection != null && _connection.IsOpen){_connection.Close();_connection.Dispose();}}}
      }
      

相关文章:

封装 RabbitMQ 消息代理交互的功能

封装了与 RabbitMQ 消息代理交互的功能&#xff0c;包括发送和接收消息&#xff0c;以及管理连接和通道。 主要组件 依赖项&#xff1a; 代码使用了多个命名空间&#xff0c;包括 Microsoft.Extensions.Configuration&#xff08;用于配置管理&#xff09;、RabbitMQ.Client&a…...

关于ffmpeg的简介和使用总结

主要参考&#xff1a; 全网最全FFmpeg教程&#xff0c;从新手到高手的蜕变指南 - 知乎 (zhihu.com) FFmpeg入门教程&#xff08;非常详细&#xff09;从零基础入门到精通&#xff0c;看完这一篇就够了。-CSDN博客 FFmpeg教程&#xff08;超级详细版&#xff09; - 个人文章 - S…...

计算机图形学编程(使用OpenGL和C++)(第2版)学习笔记 08.阴影

阴影 没有阴影的渲染效果如下&#xff0c;看起来不真实&#xff1a; 有阴影的渲染效果如下&#xff0c;看起来真实&#xff1a; 显示阴影有两种方式&#xff0c;一种是原书中的方式&#xff0c;另一种是采用光线追踪技术&#xff0c;该技术可以参考ShaderToy学习笔记 08.阴…...

[面试]SoC验证工程师面试常见问题(七)低速接口篇

SoC验证工程师面试常见问题(七)低速接口篇 摘要:低速接口是嵌入式系统和 SoC (System on Chip) 中常用的通信接口,主要用于设备间的短距离、低带宽数据传输。相比高速接口(如 PCIe、USB 3.0),低速接口的传输速率较低(通常在 kbps 到几 Mbps 范围),但具有简单…...

算法训练营第十三天|226.翻转二叉树、101. 对称二叉树、 104.二叉树的最大深度、111.二叉树的最小深度

递归 递归三部曲&#xff1a; 1.确定参数和返回值2.确定终止条件3.确定单层逻辑 226.翻转二叉树 题目 思路与解法 第一想法&#xff1a; 递归&#xff0c;对每个结点进行反转 # Definition for a binary tree node. # class TreeNode: # def __init__(self, val0, le…...

电子电器架构 --- 车载网关的设计

我是穿拖鞋的汉子&#xff0c;魔都中坚持长期主义的汽车电子工程师。 老规矩&#xff0c;分享一段喜欢的文字&#xff0c;避免自己成为高知识低文化的工程师&#xff1a; 钝感力的“钝”&#xff0c;不是木讷、迟钝&#xff0c;而是直面困境的韧劲和耐力&#xff0c;是面对外界…...

`C_PiperInterface` 类接口功能列表

C_PiperInterface 类接口功能列表 C_PiperInterface 提供了全面的接口&#xff0c;用于控制 Piper 机械臂的运动、查询状态、设置参数以及管理 SDK 限制。 官仓链接 以下是 C_PiperInterface 类中所有接口的功能总结&#xff1a; 1. 初始化与连接相关接口 __new__: 实现单例…...

D. Apple Tree Traversing 【Codeforces Round 1023 (Div. 2)】

D. Apple Tree Traversing 题目大意 有一个包含 n n n 个节点的苹果树&#xff0c;初始时每个节点上有一个苹果。你有一张纸&#xff0c;初始时纸上没有任何内容。 你需要通过以下操作遍历苹果树&#xff0c;直到所有苹果都被移除&#xff1a; • 选择一个苹果路径 ( u , v…...

Docker镜像搬运工:save与load命令的实战指南

在日常的容器化开发中&#xff0c;镜像的搬运和部署是每个开发者必须掌握的技能。今天我们将深入探讨Docker的"save"和"load"这对黄金搭档&#xff0c;揭秘它们在镜像管理中的妙用。 一、基础认知&#xff1a;镜像的打包与解包 docker save 和 docker loa…...

查看Electron 应用的调试端口

以下是一些可以知道已发布第三方 Electron 应用调试端口的方法&#xff1a; * **通过命令行参数查看** &#xff1a; * 如果该 Electron 应用在启动时添加了类似 --remote-debugging-portxxxx 或 --inspectxxxx 的参数&#xff0c;那么其调试端口就是该参数指定的端口号。比…...

各种环境测试

加载测试专用属性 当在测试时想要加入某些配置且对其他测试类不产生影响是可以用Import注释添加配置 测试类中启动web环境 默认为none不开启...

腾讯云低代码实战:零基础搭建家政维修平台

目录 1. 欢迎与项目概览1.1 教程目的与受众1.2 项目愿景与目标&#xff1a;我们要搭建一个怎样的平台&#xff1f;1.3 平台核心构成与架构解析1.4 技术栈选择与考量1.5 如何高效阅读本教程 欢迎来到“腾讯云云开发低代码实战&#xff1a;从零搭建家政维修服务平台”开发教程&am…...

居然智家亮相全零售AI火花大会 AI大模型赋能家居新零售的进阶之路

当人工智能技术以摧枯拉朽之势重构商业世界时&#xff0c;零售业正在经历一场静默而深刻的革命。在这场变革中&#xff0c;居然智家作为新零售领域的创新标杆&#xff0c;凭借其在AI技术应用上的超前布局和持续深耕&#xff0c;已悄然构建起从消费场景到产业生态的智能化闭环。…...

微服务6大拆分原则

微服务6大拆分原则 微服务拆分是指将一个大型应用程序拆分成独立服务的过程&#xff0c;在微服务拆分时&#xff0c;需要考虑以下6大微服务拆分原则 一、单一职责原则 微服务单一职责原则&#xff0c;是指每个微服务应该专注于解决一个明确定义的业务领域或功能&#xff0c;…...

进程间通信--管道【Linux操作系统】

文章目录 进程间通信&#xff08;IPC&#xff09;进程间通信的目的1. 数据交换2. 资源共享3. 进程协同4. 系统解耦5. 分布式计算IPC 的典型方式对比总结 进程间通信的前提 匿名管道匿名管道的原理创建匿名管道的过程如果不关闭不需要的读写端会怎样&#xff1f;为什么父进程要同…...

模型实时自主训练系统设计

模型实时自主训练系统设计 一、系统架构 #mermaid-svg-MLuTBuo7ehvStoqS {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-MLuTBuo7ehvStoqS .error-icon{fill:#552222;}#mermaid-svg-MLuTBuo7ehvStoqS .error-text{f…...

5.1 神经网络: 层和块

1 层&#xff08;Layer&#xff09; 1.1 定义 层是深度学习模型中的基本构建单元&#xff0c;它由一组神经元组成&#xff0c;负责对输入数据进行特定的数学运算和变换&#xff0c;以提取数据的某种特征或表示。每一层可以看作是一个函数&#xff0c;它接收输入数据&#xff…...

鸿蒙系统使用ArkTS开发语言支持身份证阅读器、社保卡读卡器等调用二次开发SDK

har库导入&#xff1a; { "license": "", "devDependencies": {}, "author": "", "name": "entry", "description": "Please describe the basic information.", &qu…...

【Bootstrap V4系列】学习入门教程之 组件-输入组(Input group)

Bootstrap V4系列 学习入门教程之 组件-输入组(Input group) 输入组(Input group)Basic example一、Wrapping 包装二、Sizing 尺寸三、Multiple inputs 多输入四、Multiple addons 多个插件五、Button addons 按钮插件六、Buttons with dropdowns 带下拉按钮七、Custom for…...

图像处理篇--- HTTP|RTSP|MJPEG视频流格式

文章目录 前言一、MJPEG (Motion JPEG)基本概念技术特点编码方式传输协议数据格式 优势实现简单低延迟兼容性好容错性强 劣势带宽效率低不支持音频缺乏标准控制 典型应用 二、RTSP (Real Time Streaming Protocol)基本概念技术特点协议栈工作流程传输模式 优势专业流媒体支持高…...

`RotationTransition` 是 Flutter 中的一个动画组件,用于实现旋转动画效果

RotationTransition 是 Flutter 中的一个动画组件&#xff0c;用于实现旋转动画效果。它允许你对子组件进行动态的旋转变换&#xff0c;从而实现平滑的动画效果。RotationTransition 通常与 AnimationController 和 Tween 一起使用&#xff0c;以控制动画的开始、结束和过渡效果…...

养生:开启健康生活的密钥

在快节奏的现代生活中&#xff0c;养生已成为追求健康的重要方式。从饮食、运动到生活习惯&#xff0c;每一个细节都关乎身体的健康。以下为你介绍科学养生的实用方法&#xff0c;助你打造健康生活。 饮食养生&#xff1a;均衡营养&#xff0c;滋养身体 合理的饮食是养生的基…...

大模型微调算法原理:从通用到专用的桥梁

前言 本文聚焦大模型落地中的核心矛盾——理论快速发展与实际应用需求之间的脱节,并系统探讨微调技术作为解决这一矛盾的关键手段。尽管大模型展现出强大的通用能力,但其在垂直领域的直接应用仍面临适配性不足、计算成本高等挑战。微调通过在预训练模型基础上进行针对性优化,…...

引言:Client Hello 为何是 HTTPS 安全的核心?

当用户在浏览器中输入 https:// 时&#xff0c;看似简单的操作背后&#xff0c;隐藏着一场加密通信的“暗战”。Client Hello 作为 TLS 握手的首个消息&#xff0c;不仅决定了后续通信的加密强度&#xff0c;还可能成为攻击者的突破口。据统计&#xff0c;超过 35% 的网站因 TL…...

深度学习中的目标检测:从 PR 曲线到 AP

深度学习中的目标检测&#xff1a;从 PR 曲线到 AP 在目标检测任务中&#xff0c;评估模型的性能是非常重要的。通过使用不同的评估指标和标准&#xff0c;我们可以量化模型的准确性与效果。今天我们将重点讨论 PR 曲线&#xff08;Precision-Recall Curve&#xff09;、平均精…...

测试左移系列-产品经理实战-实战认知1

课程&#xff1a;B站大学 记录产品经理实战项目系统性学习&#xff0c;从产品思维&#xff0c;用户画像&#xff0c;用户体验&#xff0c;增长数据驱动等不同方向理解产品&#xff0c;从0到1去理解产品从需求到落地的全过程&#xff0c;测试左移方向&#xff08;靠近需求、设计…...

数据集-目标检测系列- 烟雾 检测数据集 smoke >> DataBall

数据集-目标检测系列- 消防 浓烟 检测数据集 smoke>> DataBall 数据集-目标检测系列- 烟雾 检测数据集 smoke &#xff1e;&#xff1e; DataBall * 相关项目 1&#xff09;数据集可视化项目&#xff1a;gitcode: https://gitcode.com/DataBall/DataBall-detections-10…...

概率论与数理统计基础学习大纲

📅 课程规划 阶段一:基础入门(第1-3周) 目标:掌握概率基础和基本分布 核心知识点: 概率论的基本概念:随机事件、样本空间、概率公理条件概率与全概率公式:贝叶斯公式、事件独立性随机变量与分布:离散型和连续型随机变量常见分布: 离散:二项分布、泊松分布连续:…...

5大B2B数字营销社群营销标杆案例TOB企业数字化营销内容营销AI营销培训讲师培训师专家顾问唐兴通分享

全球B2B数字营销领域的企业社区&#xff08;或BBS&#xff09;标杆案例 在全球TOB&#xff08;企业对企业&#xff09;和B2B数字营销实践中&#xff0c;构建企业社区或在线论坛&#xff08;BBS的现代演变&#xff09;已成为增强客户关系、驱动产品采用、获取市场洞察和 genera…...

OC语言学习——Foundation框架(上)

一、字符串 NSString代表字符序列不可变的字符串&#xff0c;而NSMutable代表字符序列可变的字符串。 1.1 NSString字符串及功能 通过NSString&#xff0c;我们可以&#xff1a; 1、创建字符串。2、读取文件或网络URL来初始化字符串&#xff0c;或者将字符串写入文件或URL。3…...

【Linux】基础 IO(一)

&#x1f4dd;前言&#xff1a; 这篇文章我们来讲讲Linux——基础IO主要包括&#xff1a; 文件基本概念回顾 C文件的操作介绍系统关于文件的基本操作 &#x1f3ac;个人简介&#xff1a;努力学习ing &#x1f4cb;个人专栏&#xff1a;Linux &#x1f380;CSDN主页 愚润求学 …...

ODA服务器计算节点本地硬盘状态异常的处理

近期&#xff0c;在系统巡检过程中发现一个客户的ODA服务器本地硬盘节点出现告警&#xff0c;ODAX8 X9等&#xff0c;本地硬盘是使用的240GB M.2接口的SSD盘&#xff08;卡式&#xff09;的&#xff0c;这个没有外置的指示灯可以从服务器前面板查看&#xff0c;打开服务器机箱盖…...

图像处理篇---opencv实现坐姿检测

文章目录 前言一、方法概述使用OpenCV和MediaPipe关键点检测角度计算姿态评估 二、完整代码实现三、代码说明PostureDetector类find_pose()get_landmarks()cakculate_angle()evaluate_posture() 坐姿评估标准&#xff08;可进行参数调整&#xff09;&#xff1a;可视化功能&…...

微调ModernBERT为大型语言模型打造高效“过滤器”

ModernBERT&#xff08;2024 年 12 月&#xff09;是最近发布的小型语言模型&#xff0c;由 Answer.AI、LightOn 和 HuggingFace 共同开发。它利用了现代优化技术&#xff0c;如用于 8,192 token 上下文窗口的 RoPE 和 GeGLU layers&#xff0c;在保持效率的同时提升性能。jina…...

【C++指南】STL容器的安全革命:如何封装Vector杜绝越界访问与迭代器失效?

&#x1f31f; 各位看官好&#xff0c;我是egoist2023&#xff01; &#x1f30d; 种一棵树最好是十年前&#xff0c;其次是现在&#xff01; &#x1f680; 使用STL的三个境界&#xff1a;能用&#xff0c;明理&#xff0c;能扩展 &#x1f44d; 如果觉得这篇文章有帮助&#…...

Linux在web下http加密和配置虚拟主机及动态页面发布

web服务器的数据加密 1.简介&#xff1a;由于http协议以明文方式发送&#xff0c;不提供任何方式的数据加密&#xff0c;也不适合传输一些重要的信息&#xff0c;如银行卡号、密码等&#xff0c;解决该缺陷设计了安全套接字层超文本传输协议https&#xff1b; 2.https的握手流…...

8.2.CICD自动化

目录 一、持续集成&#xff08;CI&#xff09;核心实践 代码质量管理 • 静态代码分析&#xff1a;SonarQube规则定制&#xff08;安全漏洞、代码异味检测&#xff09; • 单元测试覆盖率&#xff1a;Jacoco报告生成与阈值控制&#xff08;覆盖率≥80%&#xff09; • 代码风格…...

解密数据结构之位图和布隆过滤器

位图和布隆过滤器 前言:笔者在前面分享过哈希的知识&#xff0c;但是笔者在哈希那篇博客中并没有给出哈希的应用场景&#xff0c;今天笔者分享的知识是关于哈希的应用&#xff0c;也就是大名鼎鼎的位图和布隆过滤器。1.位图的定义位图解决 2.位图实现1.先使用命名空间封装&…...

《从零构建大模型》PDF下载(中文版、英文版)

内容简介 本书是关于如何从零开始构建大模型的指南&#xff0c;由畅销书作家塞巴斯蒂安• 拉施卡撰写&#xff0c;通过清晰的文字、图表和实例&#xff0c;逐步指导读者创建自己的大模型。在本书中&#xff0c;读者将学习如何规划和编写大模型的各个组成部分、为大模型训练准备…...

Linux的web服务器的部署和优化

http中访问请求中I/O结构 在HTTP协议中&#xff0c;I/O&#xff08;输入/输出&#xff09;结构主要涉及客户端与服务器之间的请求和响应交互。以下是HTTP请求和响应的基本结构及其关键组成部分&#xff1a; HTTP请求结构 HTTP请求由请求行、请求头和请求体三部分组成 请求行…...

vue2 上传pdf,拖拽盖章,下载图片

效果图片&#xff1a; 不多废话上代码&#xff1a; <template><div class"pdf-stamp" onbeforecopyreturn false onselectdocument.selection.empty() ondragstartreturn false onselectstart return false ><div class"scroll-box" scro…...

MindSpore框架学习项目-ResNet药物分类-模型训练

目录 3.模型训练 3.1模型训练 3.1.1 定义优化器和损失函数 定义优化器和损失函数代码解析 3.1.2定义训练、推理函数 定义训练、推理函数代码解释 3.2模型保存 模型保存代码说明 3.3绘制acc和loss的曲线 参考内容&#xff1a; 昇思MindSpore | 全场景AI框架 | 昇思Mind…...

Jsp技术入门指南【十二】自定义标签

Jsp技术入门指南【十二】自定义标签 前言一、什么是标签二、标签的类型有哪些&#xff1f;1. 空标签2. 带有属性的标签3. 带主体的标签 三、自定义标签的部件3.1 自定义标签的四步骤3.2 标签处理程序3.3 自定义标签的开发及使用步骤第一步&#xff1a;创建标签助手类第二步&…...

数据库故障排查指南:从连接问题和性能优化

数据库作为现代应用程序的核心组件&#xff0c;其稳定性和性能直接影响整个系统的运行。然而&#xff0c;数据库在运行过程中常常会遇到各种故障&#xff0c;如连接失败、性能下降、数据不一致等问题。本文将从实际问题出发&#xff0c;结合代码示例和工具使用&#xff0c;系统…...

材料创新与工艺升级——猎板PCB引领高频阻抗板制造革命

在5G通信、AI服务器和自动驾驶的推动下&#xff0c;高频电路对信号完整性的要求日益严苛。猎板PCB作为国内高端PCB制造的标杆企业&#xff0c;通过材料创新与工艺革新&#xff0c;实现了阻抗控制的突破性进展&#xff0c;为行业树立了新标杆。 1. 高频材料的突破 传统FR-4基材…...

GitHub 趋势日报 (2025年05月09日)

本日报由 TrendForge 系统生成 https://trendforge.devlive.org/ &#x1f310; 本日报中的项目描述已自动翻译为中文 &#x1f4c8; 今日整体趋势 Top 10 排名项目名称项目描述今日获星总星数语言1voideditor/void⭐ 1879⭐ 15214TypeScript2ruanyf/weekly科技爱好者周刊&…...

SaaS场快订平台项目说明【持续更新】

一、项目介绍 SaaS场快订平台是一个高效、便捷的体育场馆在线预订平台。本项目采用SaaS方式开发&#xff0c;用户不需要安装软件&#xff0c;直接通过互联网访问在线程序即可使用。本项目主要构建了一个体育馆预订系统&#xff0c;项目的功能主要包括&#xff1a;用户注册与登…...

PyTorch API 7 - TorchScript、hub、矩阵、打包、profile

文章目录 torch.hub发布模型如何实现入口点&#xff1f;重要通知 从Hub加载模型运行加载的模型&#xff1a;下载的模型保存在哪里&#xff1f;缓存逻辑已知限制&#xff1a; TorchScript创建 TorchScript 代码混合使用追踪与脚本化TorchScript 语言内置函数与模块PyTorch 函数与…...

OpenVLA:开源的视觉-语言-动作模型

1. 简介 让我们先来介绍一下什么是OpenVLA&#xff0c;在这里&#xff1a; https://openvla.github.io/ 可以看到他们的论文、数据、模型。 OpenVLA 是一个拥有 70亿参数的开源 **视觉-语言-动作&#xff08;VLA&#xff09;**模型。它是在 Open X-Embodiment 数据集 中的 97万…...

android HashMap和List该如何选择

目录 一&#xff0c;ArrayList 1.1 数组 1.2 扩容 1.3 查询 1.4 插入&#xff0c;删除 1.5 小结 二&#xff0c;LinkedList 2.1 链表 2.2 查找 2.3 插入 2.4 小结 三&#xff0c;HashMap 扩容 四&#xff0c;SparseArray 五&#xff0c;ArrayMap 一&#xff0c;ArrayList 1.…...