Swift Combine 学习(六):自定义 Publisher 和 Subscriber
- Swift Combine 学习(一):Combine 初印象
- Swift Combine 学习(二):发布者 Publisher
- Swift Combine 学习(三):Subscription和 Subscriber
- Swift Combine 学习(四):操作符 Operator
- Swift Combine 学习(五):Backpressure和 Scheduler
- Swift Combine 学习(六):自定义 Publisher 和 Subscriber
- Swift Combine 学习(七):实践应用场景举例
文章目录
- 引言
- 错误处理和重试机制
- 调试 Combine 代码
- 自定义 Publisher 和 Subscriber
- 结语
引言
在前面的文章中,我们已经学习了 Combine 框架的核心概念和基础组件。本文将探讨如何自定义 Publisher 和 Subscriber,以满足特定的应用需求。通过自定义这些组件,开发者可以创建更加灵活和强大的数据流处理逻辑,适应不同的应用场景。
错误处理和重试机制
Combine 提供了多种处理错误和实现重试机制方法。以下是一些常用的错误处理操作符:
- 使用
tryMap
进行错误检查和抛出。 - 使用
retry
操作符在失败时进行重试。 - 使用
catch
操作符处理错误并提供 fallback 值。
import Combine
import Foundationenum ErrorType: Error {case numberTooLarge
}var cancellables = Set<AnyCancellable>()let numbers = [2, 5, 11, 99].publisher.tryMap { number -> Int in// 检查数字是否大于10guard number <= 10 else {throw ErrorType.numberTooLarge}return number * 2}.retry(1).catch { error -> AnyPublisher<Int, Never> in// 出错就默认返回 0print("❌ 错误: \(error)")return Just(0).eraseToAnyPublisher()}.eraseToAnyPublisher()print("🍎 开始处理数字")
numbers.sink { number inprint("📍 结果: \(number)")}.store(in: &cancellables)/*输出:
🍎 开始处理数字
📍 结果: 4
📍 结果: 10
📍 结果: 4
📍 结果: 10
❌ 错误: numberTooLarge
📍 结果: 0
*/
调试 Combine 代码
响应式编程因为传统的堆栈跟踪信息不足、异步执行和线程切换、一些操作符的链式调用可能使得代码逻辑比较抽象等等原因导致其一大痛点就是出现 bug 不好排查。Swift Combine 提供了几个有用的操作符来帮助调试:
- 使用
print
打印所有事件。 - 使用
breakpoint
在特定条件下触发断点。 - 使用
handleEvents
在发布者生命周期的各个阶段插入自定义的调试代码。
import Combineclass CombineDebugDemo {private var cancellables = Set<AnyCancellable>()// MARK: - 使用 print 操作符追踪数据流func basicDebugDemo() {let numbers = (6...7).publisherlet printDemo = numbers.print("🔍 数据流追踪")printDemo.sink { print("Print演示完成: \($0)") }receiveValue: { print("Print值: \($0)") }.store(in: &cancellables)}// MARK: - breakpoint 条件断点func breakpointDemo() {let numbers = (7...9).publisherlet breakpointDemo = numbers.breakpoint(receiveOutput: { value inlet shouldBreak = value > 10print("⚡️ 断点检查: 值 = \(value), 是否触发 = \(shouldBreak)")return shouldBreak})breakpointDemo.sink { print("断点演示完成: \($0)") }receiveValue: { print("断点值: \($0)") }.store(in: &cancellables)}// MARK: - 使用 handleEvents 监控完整生命周期func handleEventsDemo() {let numbers = (5...7).publisherlet handleEventsDemo = numbers.handleEvents(receiveSubscription: { subscription inprint("🌟订阅开始: \(subscription)")},receiveOutput: { value inprint("⌛️准备发送值: \(value)")},receiveCompletion: { completion inprint("✅发送完成: \(completion)")},receiveCancel: {print("❌订阅取消")},receiveRequest: { demand inprint("📧收到需求: \(demand)")})handleEventsDemo.sink { print("事件处理演示完成: \($0)") }receiveValue: { print("事件处理值: \($0)") }.store(in: &cancellables)}// MARK: - 综合例子展示func comprehensiveDebugDemo() {let numbers = (16...18).publishernumbers// 1. 原始数据.print("\n1️⃣ 原始数据")// 2. 添加条件断点(可选).breakpoint(receiveOutput: { value inlet shouldBreak = value > 16print("2️⃣ 断点检查: 值 = \(value), 触发 = \(shouldBreak)")return shouldBreak})// 3. 完整的生命周期输出.handleEvents(receiveSubscription: { _ in print("3️⃣ 订阅开始") },receiveOutput: { print("3️⃣ 输出值: \($0)") },receiveCompletion: { print("3️⃣ 完成: \($0)") },receiveCancel: { print("3️⃣ 取消") },receiveRequest: { print("3️⃣ 需求: \($0)") }).sink(receiveCompletion: { print("4️⃣ 最终完成: \($0)") },receiveValue: { print("4️⃣ 最终值: \($0)") }).store(in: &cancellables)}
}let demo = CombineDebugDemo()print("\n🍎基础 print")
demo.basicDebugDemo()print("\n🍎断点演示")
demo.breakpointDemo()print("\n🍎事件处理演示")
demo.handleEventsDemo()print("\n🍎综合调试演示")
demo.comprehensiveDebugDemo()/*输出🍎基础 print
🔍 数据流追踪: receive subscription: (6...7)
🔍 数据流追踪: request unlimited
🔍 数据流追踪: receive value: (6)
Print值: 6
🔍 数据流追踪: receive value: (7)
Print值: 7
🔍 数据流追踪: receive finished
Print演示完成: finished🍎断点演示
⚡️ 断点检查: 值 = 7, 是否触发 = false
断点值: 7
⚡️ 断点检查: 值 = 8, 是否触发 = false
断点值: 8
⚡️ 断点检查: 值 = 9, 是否触发 = false
断点值: 9
断点演示完成: finished🍎事件处理演示
🌟订阅开始: 5...7
📧收到需求: unlimited
⌛️准备发送值: 5
事件处理值: 5
⌛️准备发送值: 6
事件处理值: 6
⌛️准备发送值: 7
事件处理值: 7
✅发送完成: finished
事件处理演示完成: finished🍎综合调试演示1️⃣ 原始数据: receive subscription: (16...18)
3️⃣ 订阅开始
3️⃣ 需求: unlimited1️⃣ 原始数据: request unlimited1️⃣ 原始数据: receive value: (16)
2️⃣ 断点检查: 值 = 16, 触发 = false
3️⃣ 输出值: 16
4️⃣ 最终值: 161️⃣ 原始数据: receive value: (17)
2️⃣ 断点检查: 值 = 17, 触发 = true
3️⃣ 输出值: 17
4️⃣ 最终值: 171️⃣ 原始数据: receive value: (18)
2️⃣ 断点检查: 值 = 18, 触发 = true
*/
自定义 Publisher 和 Subscriber
iOS 大部分场景下开发者无需自定义 Publisher,因为有 KVO 、 Notification 等。不过有时可能需要创建自定义的 Publisher 或 Subscriber 来满足特定需求。比如封装已经有的异步 API 、有特殊的数据传递需求、实现一些当前 Combine 操作符无法满足的功能的时候。
-
创建一个自定义的 TimerPublisher。这个 TimerPublisher 将模拟一个计时器,每秒发布一个整数值。然后写一个自定义 TimerSubscriber 用于接收从 TimerPublisher 发布的值,并做相应的处理,例如在控制台中打印出接收到的值。
import Combine import Foundation// 自定义 Publisher class TimerPublisher: Publisher, @unchecked Sendable {// 定义 Publisher 的输出类型和失败类型typealias Output = Inttypealias Failure = Neverprivate var counter = 0private var timer: Timer?// 使用 dictionary 存储多个订阅者及其需求private var subscribers: [UUID: (subscriber: AnySubscriber<Output, Failure>, demand: Subscribers.Demand)] = [:]deinit {stop()}// 接受 Subscriber 并建立连接func receive<S>(subscriber: S) where S : Subscriber, TimerPublisher.Failure == S.Failure, TimerPublisher.Output == S.Input {let id = UUID()// 创建一个 Subscription 并将其传递给 Subscriberlet subscription = TimerSubscription(id: id, publisher: self)subscribers[id] = (AnySubscriber(subscriber), .none)subscriber.receive(subscription: subscription)}// 开始func start() {guard timer == nil else { return }timer = Timer.scheduledTimer(withTimeInterval: 1.0, repeats: true) { [weak self] _ inself?.processValue()}}func stop() {timer?.invalidate()timer = nil// 发送完成信号给所有订阅者subscribers.values.forEach { $0.subscriber.receive(completion: .finished) }subscribers.removeAll()}// 处理订阅者的 demandfileprivate func updateDemand(for id: UUID, with newDemand: Subscribers.Demand) {if let subscriberInfo = subscribers[id] {subscribers[id] = (subscriberInfo.subscriber, subscriberInfo.demand + newDemand)}}// 取消特定订阅者fileprivate func cancelSubscription(for id: UUID) {subscribers.removeValue(forKey: id)if subscribers.isEmpty {stop()}}// 处理发送private func processValue() {counter += 1// 为每个有需求的订阅者发送值subscribers = subscribers.mapValues { subscriberInfo invar currentDemand = subscriberInfo.demand// 只在有需求时发送值if currentDemand > .none {// 直接用 receive 返回的 Demandlet newDemand = subscriberInfo.subscriber.receive(counter)currentDemand += newDemandcurrentDemand -= 1}return (subscriberInfo.subscriber, currentDemand)}}// 自定义 Subscriptionprivate class TimerSubscription: Subscription {private var id: UUIDprivate weak var publisher: TimerPublisher?init(id: UUID, publisher: TimerPublisher) {self.id = idself.publisher = publisher}// 处理 Subscriber 的请求func request(_ demand: Subscribers.Demand) {publisher?.updateDemand(for: id, with: demand)publisher?.start()}func cancel() {publisher?.cancelSubscription(for: id)}} }// 自定义 Subscriber class TimerSubscriber: Subscriber {let name: Stringinit(name: String) {self.name = name}// 指定输入、失败类型typealias Input = Inttypealias Failure = Neverfunc receive(subscription: Subscription) {print("\(name): 订阅已开始")subscription.request(.max(3)) // 限制接收3个值}func receive(_ input: Int) -> Subscribers.Demand {print("\(name): 接收到的值: \(input)")return .none // 不请求更多的值}func receive(completion: Subscribers.Completion<Never>) {print("\(name): 订阅完成")} }let timerPublisher = TimerPublisher()// 创建多个 subscriber let subscriber1 = TimerSubscriber(name: "订阅者1") let subscriber2 = TimerSubscriber(name: "订阅者2")// 订阅 timerPublisher.receive(subscriber: subscriber1) timerPublisher.receive(subscriber: subscriber2)// 5秒后停止发布 DispatchQueue.main.asyncAfter(deadline: .now() + 5) {timerPublisher.stop() }/* 输出: 订阅者1: 订阅已开始 订阅者2: 订阅已开始 订阅者1: 接收到的值: 1 订阅者2: 接收到的值: 1 订阅者1: 接收到的值: 2 订阅者2: 接收到的值: 2 订阅者1: 接收到的值: 3 订阅者2: 接收到的值: 3 订阅者1: 订阅完成 订阅者2: 订阅完成 */
结语
自定义 Publisher 和 Subscriber 为开发者提供了更大的灵活性,能够根据具体需求扩展 Combine 框架的功能。通过掌握自定义组件的技巧,开发者可以打造出更具适应性和扩展性的应用。在下一篇文章中,将通过实际案例来展示 Combine 的贴合日常开发的简化的应用场景,帮助更好地理解和应用。
- Swift Combine 学习(七):实践应用场景举例
相关文章:
Swift Combine 学习(六):自定义 Publisher 和 Subscriber
Swift Combine 学习(一):Combine 初印象Swift Combine 学习(二):发布者 PublisherSwift Combine 学习(三):Subscription和 SubscriberSwift Combine 学习(四&…...
服务器网卡绑定mode和交换机的对应关系
互联网各领域资料分享专区(不定期更新): Sheet 模式类别 网卡绑定mode共有七种(0~6): bond0、bond1、bond2、bond3、bond4、bond5、bond6 mode详解 mode0 ,即:(balance-rr) Round-robin policy(平衡轮循环策略,需要配置交换机静态聚合) mode…...
【动手学轨迹预测】2.4 考虑地图拓扑关系的表征方法
上一节我们介绍了VectorNet提出了矢量化场景表征方法, 大幅提高了预测网络编码性能. 但是VectorNet对地图数据的编码是基于无向无权图的, 并没有考虑到地图的拓扑关系. 显然在预测中, 地图的拓扑关系应该被考虑到. 于是在VectorNet的基础上, LaneGCN提出一种将地图车道作为节点…...
ChatGLM3模型搭建(踩坑记录版)
参考 魔搭社区 https://zhuanlan.zhihu.com/p/720148240 智谱AI通用大模型:本地部署ChatGLM3-6B开源大模型 - 编程库 说明 搭建方式多篇文章结合着看; 模型下载强烈推荐魔塔社区下载ZhipuAI/chatglm3-6b; 官方github指定清华的模型没有…...
基于 Python Django 的花卉商城系统的研究与实现
博主介绍:✌程序员徐师兄、7年大厂程序员经历。全网粉丝12w、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取源码联系🍅 👇🏻 精彩专栏推荐订阅👇…...
Spring Boot 3 文件下载、多文件下载以及大文件分片下载、文件流处理、批量操作 和 分片技术
在 Spring Boot 3 中,实现文件下载、多文件下载以及大文件分片下载需要结合以下功能:文件流处理、批量操作 和 分片技术。以下是详细实现方案: 1. 单文件下载 基础的单文件下载实现,可以参考以下代码: GetMapping(&…...
什么是事件循环(Event Loop)?请谈谈它在 JavaScript 中的作用?
事件循环(Event Loop)是什么? 事件循环(Event Loop)是JavaScript运行时环境(如浏览器或Node.js)中的一个核心机制,用于处理异步操作和事件。 它负责协调代码的执行、事件的处理、以…...
Lua : Coroutine(协程)
Lua 协程(coroutines)是一种强大的控制结构,允许函数在执行过程中暂停并在稍后恢复。与线程不同,协程是非抢占式的,这意味着它们不会被操作系统调度,而是由程序显式地切换。协程在 Lua 中非常有用ÿ…...
【2024华为OD-E卷-200分-跳格子2】(题目+思路+JavaC++Python解析)
题目描述 在一个二维平面上,有一个 n x m 的网格,每个格子有一个非负整数。你从左上角 (0, 0) 开始,每次只能向右或向下移动,目标是到达右下角 (n-1, m-1)。 在移动过程中,你需要记录经过的格子中,最大数…...
【仓颉语言基础】语言概念、环境配置与语法解析
华为仓颉语言是一门专为分布式系统设计的现代编程语言,以简洁的语法和强大的分布式能力为核心,提供高效的资源管理和任务调度方案。本篇文章将带您从概念入手,逐步掌握环境配置与语法基础,为分布式开发奠定坚实基础。 文章目录 一…...
LeetCode - 初级算法 数组(删除排序数组中的重复项)
免责声明:本文来源于个人知识与公开资料,仅用于学术交流。 删除排序数组中的重复项 这篇文章讨论如何从一个非严格递增的数组 nums 中删除重复的元素,使每个元素只出现一次,并返回新数组的长度。因为数组是排序的,只要是相同的肯定是挨着的,所以我们需要遍历所有数组,然…...
SpringMVC进阶(自定义拦截器以及异常处理)
文章目录 1.自定义拦截器 1.基本介绍 1.说明2.自定义拦截器的三个方法3.流程图 2.快速入门 1.Myinterceptor01.java2.FurnHandler.java3.springDispatcherServlet-servlet.xml配置拦截器4.单元测试 3.拦截特定路径 1.拦截指定路径2.通配符配置路径 4.细节说明5.多个拦截器 1.执…...
2 秒杀系统架构
第一步 思考面临的问题和业务场景 秒杀系统面临的问题: 短时间内并发非常高,如果按照秒杀的并发做相应的承载会造成大量资源的浪费。第二解决超卖的问题。 第二步 思考目前的处境和解决方案 因为秒杀系统属于短时间内的高并发问题,我们不可能使用那么…...
C++如何遍历数组vector
在C中,vector是一个可变数组。那么怎么遍历它呢?我们以for循环为例(while循环,大家自己脑补)。 方法一: 基于范围的for循环,这是C11新引入的。 std::vector<int> v {1, 2, 3, 4, 5, 6…...
ubuntu非root用户操作root权限问题-virbox挂在共享文件夹
首先讲一下,virtuallbox 挂在文件夹,操作的时候总是需要root权限,比较费劲。 这一操作其实也正对着我们在Ubuntu上的操作。 前段时间我想在ubuntu正常用户下去操作i2c,也出现了类似的问题。 后来把正常的操作加到组里面也解决了类…...
大模型推理:vllm多机多卡分布式本地部署
文章目录 1、vLLM分布式部署 docker镜像构建通信环境配置 2、其他大模型部署工具3、问题记录参考文献 单台机器GPU资源不足以执行推理任务时,一个方法是模型蒸馏量化,结果就是会牺牲些效果。另一种方式是采用多台机器多个GPU进行推理,资源不…...
WFP Listbox绑定数据后,数据变化的刷新
Listbox绑定数据通过ItemsSource来的,如果绑定的是普通的List<数据>,不会自己刷新。 使用ObservableCollection集合 解决问题的方法: 将数组替换为 ObservableCollection ObservableCollection 是专为绑定设计的集合类型,可以通知 W…...
AI + 爬虫:智能化数据采集的未来
随着人工智能(AI)技术的不断进步,传统的网络爬虫正经历一场前所未有的变革。从规则驱动到智能化演变,AI 的引入不仅提高了爬虫的效率和适应性,更为大规模数据采集提供了全新思路。本文将深入探讨 AI 与爬虫的结合&…...
人工智能知识分享第五天-正则化.损失函数案例
正则化 欠拟合与过拟合 过拟合:一个假设 在训练数据上能够获得比其他假设更好的拟合, 但是在测试数据集上却不能很好地拟合数据 (体现在准确率下降),此时认为这个假设出现了过拟合的现象。(模型过于复杂) 欠拟合:一个假设 在训…...
WebRTC的线程事件处理
1. 不同平台下处理事件的API: Linux系统下,处理事件的API是epoll或者select;Windows系统下,处理事件的API是WSAEventSelect,完全端口;Mac系统下,kqueue 2. WebRTC下的事件处理类: …...
C++软件设计模式之迭代器模式
迭代器模式是一种行为设计模式,它允许你顺序访问一个聚合对象的元素,而不暴露其底层表示。在C软件设计中,迭代器模式的主要目的是将数据的遍历行为与数据结构本身分离,使得数据结构的修改不会影响到遍历代码。 目的和意图 解耦遍…...
git reset --hard(重置到当前提交,所有未提交的更改都会被永久丢弃)
git reset --hard 是一个强大的命令,它会将你的工作目录、暂存区和当前分支的 HEAD 指针重置到指定的提交状态,所有未提交的更改都会被永久丢弃。因此,使用这个命令时需要非常小心。 基本用法 重置到当前提交(丢弃所有未提交的更…...
三分钟在你的react项目中引入tailwindcss
前言:在vite搭建的react项目中引入并使用tailwindcss 一、初始化react项目 1、创建项目 在文件夹下右键打开终端并输入命令使用vite创建项目 pnpm create vite react-tailwind选择reactjavascript,并输入命令安装依赖并启动 2、安装tailwind pnpm …...
Android Studio学习笔记
01-课程前面的话 02-Android 发展历程 03-Android 开发机器配置要求 04-Android Studio与SDK下载安装 05-创建工程与创建模拟器...
19712 数字接龙
/*我觉得重要的理解点:1.四维数组白表示一个点从另一个点沿对角线的方式进行移动,如果这个元素的值为真则表示这样的移动存在。 2.按照0->k-1的顺序移动。这个要求的实现方法也值得学习 3.count和index的含义: index表示索引,表…...
【图像去噪】论文复现:大道至简!ZS-N2N的Pytorch源码复现,跑通源码,获得指标计算结果,补充保存去噪结果图像代码,代码实现与论文理论对应!
请先看【专栏介绍文章】:【图像去噪(Image Denoising)】关于【图像去噪】专栏的相关说明,包含适配人群、专栏简介、专栏亮点、阅读方法、定价理由、品质承诺、关于更新、去噪概述、文章目录、资料汇总、问题汇总(更新中) 完整代码和训练好的模型权重文件下载链接见本文底…...
Linux-mac地址
mac地址 由6位16进制数组成。最高字节的最低位,0表示单播地址,1表示多播地址。最高字节的第二位,0表示全局地址,1表示本地地址。 单播地址:单播MAC地址用于一对一的通信模式,即从单一的源端发送到单一的目…...
旷视科技Java面试题及参考答案
讲一下进程间的通讯方式(如管道、消息队列、共享内存、Socket 等),各有什么特点? 管道(Pipe) 管道是最早出现的进程间通信方式之一,主要用于具有亲缘关系(父子进程)的进程之间通信。 特点: 半双工通信,数据只能单向流动。例如,在一个简单的父子进程通信场景中,父进…...
【无线传感网】WSN数据管理技术
文章目录 WSN数据管理的基本概念以数据为中心的WSN数据库与分布式数据库相比具有的特殊性WSN数据管理技术的研究热点 WSN数据管理的关键技术无线传感器网络数据存储结构网外集中式存储方案网内分层存储方案网内本地存储方案以数据为中心的网内存储方案 数据查询处理技术查询类型…...
硬件基础知识笔记(2)——二级管、三极管、MOS管
Part 2 二级管、三极管、MOS管 1、二级管1.1肖特基二极管和硅二极管选型比较1.2到底是什么决定了二极管的最高工作频率?1.3二极管结电容和反向恢复时间都是怎么来的 1、二级管 1.1肖特基二极管和硅二极管选型比较 肖特基二极管的优势主要在速度和压降,对…...
记录uniapp组件swiper自适应高度
在uniapp组件swiper不能自适应高度 思路: 根据传的图片,进行图片分析宽高, 根据屏幕尺寸,进行换算对应的宽高比。 最后获得图片尺寸,进行赋值。 <swiper class="swiper" :style="{ height: `${swiperheight}` + px }" @change="onSwiperC…...
Presto-简单了解-230403
presto是什么了解一下: 秒级查询引擎(不做存储),GB-PB级不依赖于yarn,有自己的资源管理和执行计划支持多种数据源:hive、redis、kafka presto架构 presto优缺点 presto优点 内存到内存的传输࿰…...
Windows Knowledge
1 GRUB简介 1.1 MBR和PBR MBR分为GRUB.MBR和DOS.MBR。 由于硬盘上扇区从偏移0到偏移62属于同一个磁道0,虽然DOS.MBR仅占用一个扇区,但是需要将DOS.MBR后面的偏移1到偏移62保留,所以磁盘上第一个分区的第一个扇区是从偏移63开始的。fbinst软件…...
【Rust自学】9.1. 不可恢复的错误以及panic!
喜欢的话别忘了点赞、收藏加关注哦,对接下来的教程有兴趣的可以关注专栏。谢谢喵!(・ω・) 9.1.1. Rust错误处理概述 Rust拥有极高的可靠性,这也延伸到了错误处理的领域。比如说在大部分情况下,Rust会迫使你…...
UE5 Debug的一些心得
1、BUG粗略可分为两类: 一种是显性的,编译直接就通不过,必须马上解决。 第二种是隐性的,新功能完成后,编译成功顺利运行,洋洋自得,而问题隐藏在幕后,测试之后才逐渐发现有问题&…...
Docker Compose 构建 EMQX 集群 实现mqqt 和websocket
EMQX 集群化管理mqqt真香 目录 #目录 /usr/emqx 容器构建 vim docker-compose.yml version: 3services:emqx1:image: emqx:5.8.3container_name: emqx1environment:- "EMQX_NODE_NAMEemqxnode1.emqx.io"- "EMQX_CLUSTER__DISCOVERY_STRATEGYstatic"- …...
通过Xshell远程连接wsl2
目录 一、WSL网络原理 二、 下载XShell 三、Ubuntu里配置ssh 1.查看是否已经安装SSH 2.安装SSH 3.修改SSH配置 4.重启ssh 5.查看ip 四、在Xshell中链接电脑 五、设置端口转发 1.设置主机端口映射到wsl2的端口 六、防火墙设置开放8989端口 方式一(推荐): 方式二:…...
产品原型设计
🤣🤣目录🤣🤣 一、Axure原型设计(Axure RP 9 )1.1 软件下载安装1.2 产品原型展示1.3 产品原型下载1.4 视频课程推荐 二、磨刀原型设计2.1 软件下载安装2.2 产品原型展示2.3 产品原型下载2.4 视频课程推荐 什…...
【二】arcgis JavaScript api 实现加载不同坐标系的底图和三维服务
提示:如果是天地图底图参考这篇文章 【一】arcgis JavaScript api 实现加载不同坐标系的底图和三维服务_arcgis js api 调用三维地图服务-CSDN博客 需求: 前端开发实现底图(wkid:3857,web墨卡托)&#x…...
使用JMeter对Linux生产服务器进行压力测试
安装 JMeter wget https://downloads.apache.org/jmeter/binaries/apache-jmeter-5.4.1.tgz tar -xzf apache-jmeter-5.4.1.tgz cd apache-jmeter-5.4.1创建 JMeter 脚本 设置中文 选择Options—>Choose Language—>选择其他语言(例如:Chinese&am…...
mapper文件的解释
<?xml version"1.0" encoding"UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace"com.ruoyi.system.mapper.Jianai…...
利用Claude3.5点评学习LightRAG源码
原始代码为:lightrag. 以下为两次提问记录:↓↓ 1. 请从专业程序员的角度点评这段代码↓ 我来从几个方面分析这段代码: 优点 👍 代码结构清晰 使用了 dataclass 来管理配置清晰的模块化设计,将不同功能分离到不同的存储类中使用了依赖注入…...
linux查看硬件信息
1 CPU # 查看 CPU 详细信息 # 总核数 物理CPU个数 X 每颗物理CPU的核数 # 总逻辑CPU数 物理CPU个数 X 每颗物理CPU的核数 X 超线程数 cat /proc/cpuinfo# 查看物理CPU个数 cat /proc/cpuinfo| grep "physical id"| sort| uniq| wc -l# 查看每个物理CPU中core的个…...
基于单片机中药存放环境监测系统的实现
基于单片机中药存放环境监测系统的实现 项目开发背景 随着现代中药的广泛应用,中药材的存储环境对其质量有着至关重要的影响。温湿度、烟雾、火灾等环境因素,若不加以控制,将会导致中药材失效或变质。因此,设计一个基于单片机的…...
从零开始开发纯血鸿蒙应用之UI封装
从零开始开发纯血鸿蒙应用 一、题引二、UI 组成三、UI 封装原则四、实现 lib_comps1、封装 UI 样式1.1、attributeModifier 属性1.2、自定义AttributeModifier<T>类 2、封装 UI 组件 五、总结 一、题引 在开始正文前,为了大家能够从本篇博文中,汲…...
0101java面经
1.Java 中有哪些垃圾回收算法? 标记 - 清除算法(Mark - Sweep) 基本原理:标记 - 清除算法是最基础的垃圾回收算法之一。它分为两个阶段,首先是标记阶段,从根对象(如栈帧中的局部变量、静态变量等引用的对…...
逐行讲解大模型流式输出 streamer 源码
目录 简介TextStreamer 基础流式输出TextIterateStreamer 迭代器流式输出本地代码模型加载并前端展示streamlit 输出显示gradio 输出显示 vllm 部署模型并前端展示streamlit 输出显示gradio 输出显示 备注 简介 本文详细讲解了大模型流式输出的源码实现,包括TextSt…...
springboot533图书管理系统(论文+源码)_kaic
摘 要 传统信息的管理大部分依赖于管理人员的手工登记与管理,然而,随着近些年信息技术的迅猛发展,让许多比较老套的信息管理模式进行了更新迭代,图书信息因为其管理内容繁杂,管理数量繁多导致手工进行处理不能满足广…...
Dell服务器升级ubuntu 22.04失败解决
ubuntu系统原版本20.04,服务器dell T40. 执行apt update后,再执行apt upgrade。 apt update执行成功,但apt upgrade执行中断,提示如下: Checking package manager Reading package lists... Done Building dependen…...
sql列转行 行转列
列转行 在 SQL 中,转换数据以按列排列的值成为按行排列的值(即所谓的“列转行”或“列转行”)是常见的数据操作需求。这个操作在不同的数据库管理系统中可以通过不同的技术手段来实现。以下是几种常见的数据库系统中实现列转行的方法&#x…...