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

Go构建高并发权重抽奖系统：从设计到优化全流程指南

news 来源：原创 2025/7/5 7:30:09

引言：为何需要专业抽奖系统？

在现代互联网应用中，抽奖系统被广泛用于营销活动、用户激励等场景。一个好的抽奖系统需要满足：

公平性：确保概率分布准确
高性能：支持高并发抽奖请求
安全性：防止作弊和重复中奖
可扩展：支持多种抽奖活动配置

本文将基于Go语言实现一个完整的权重抽奖系统，涵盖核心算法、并发控制、安全防护等关键设计。

一、系统架构设计

1. 整体架构图

2. 核心组件说明

组件	功能描述	技术实现
奖品管理	奖品CRUD、权重配置	GORM + MySQL
概率计算引擎	权重算法、随机数生成	crypto/rand + 区间算法
防重系统	用户去重、奖品防超发	Redis SET + Lua脚本
活动管理	多活动支持、时效控制	内存缓存 + 定时任务

二、核心算法实现

1. 权重区间算法

type Prize struct {ID     int    `json:"id"`Name   string `json:"name"`Weight int    `json:"weight"` // 权重值Stock  int    `json:"stock"`  // 库存
}type LotterySystem struct {prizes      []PrizetotalWeight intrwLock      sync.RWMutex
}// 预计算总权重
func (ls *LotterySystem) calcTotalWeight() {ls.totalWeight = 0for _, prize := range ls.prizes {ls.totalWeight += prize.Weight}
}// 抽奖核心算法
func (ls *LotterySystem) Draw() (*Prize, error) {ls.rwLock.Lock()defer ls.rwLock.Unlock()if ls.totalWeight <= 0 {return nil, errors.New("no available prizes")}// 使用crypto/rand生成安全随机数randNum, err := rand.Int(rand.Reader, big.NewInt(int64(ls.totalWeight)))if err != nil {return nil, err}r := randNum.Int64()var accumulated intfor i := range ls.prizes {if ls.prizes[i].Stock <= 0 {continue}accumulated += ls.prizes[i].Weightif r < int64(accumulated) {ls.prizes[i].Stock--return &ls.prizes[i], nil}}return nil, errors.New("draw failed")
}

2. 算法复杂度优化

优化策略	实现方式	性能提升
预计算总权重	初始化/配置变更时计算	O(1)获取
库存预检查	跳过库存为0的奖品	减少遍历次数
区间二分查找	对有序权重列表使用sort.Search	O(log n)查找

// 二分查找优化版本
func (ls *LotterySystem) fastDraw() (*Prize, error) {// ... 前置检查同上randNum, _ := rand.Int(rand.Reader, big.NewInt(int64(ls.totalWeight)))r := randNum.Int64()// 使用二分查找定位奖品idx := sort.Search(len(ls.prizes), func(i int) bool {return ls.prizes[i].weightAcc >= int(r)})if idx < len(ls.prizes) && ls.prizes[idx].Stock > 0 {ls.prizes[idx].Stock--return &ls.prizes[idx], nil}return nil, errors.New("draw failed")
}

三、高并发安全设计

1. 多级并发控制

type ConcurrentLottery struct {globalLock  sync.RWMutex      // 全局配置锁prizeLocks  []sync.Mutex      // 奖品粒度锁userLocks   sync.Map          // 用户ID粒度锁
}// 用户级别抽奖
func (cl *ConcurrentLottery) UserDraw(userID string) (*Prize, error) {// 用户粒度锁防止重复请求userLock, _ := cl.userLocks.LoadOrStore(userID, &sync.Mutex{})mu := userLock.(*sync.Mutex)mu.Lock()defer mu.Unlock()// 全局读锁保护配置cl.globalLock.RLock()defer cl.globalLock.RUnlock()// 抽奖逻辑...
}

2. Redis防重方案

-- redis_deny_duplicate.lua
local key = KEYS[1] -- 如 "lottery:2023:user:"..userID
local prizeID = ARGV[1]
local ttl = ARGV[2]-- 使用SETNX实现原子操作
if redis.call("SETNX", key, prizeID) == 1 thenredis.call("EXPIRE", key, ttl)return 1 -- 成功
elsereturn 0 -- 已存在记录
end

四、RESTful API设计

1. API接口规范

端点	方法	描述	参数
/api/lottery	POST	参与抽奖	{user_id, activity_id}
/api/prizes	GET	获取奖品列表	activity_id
/api/result/{id}	GET	查询中奖结果	result_id
/api/admin/prize	POST	管理员添加奖品	{activity_id, prize_info}

2. 抽奖接口实现

func (s *Server) handleLottery(c *gin.Context) {var req struct {UserID     string `json:"user_id" binding:"required"`ActivityID string `json:"activity_id" binding:"required"`}// 1. 参数校验if err := c.ShouldBindJSON(&req); err != nil {c.JSON(400, gin.H{"error": err.Error()})return}// 2. 频率限制if !s.limiter.Allow(req.UserID) {c.JSON(429, gin.H{"error": "too many requests"})return}// 3. 执行抽奖prize, err := s.lotterySystem.Draw(req.UserID, req.ActivityID)if err != nil {c.JSON(500, gin.H{"error": err.Error()})return}// 4. 记录结果resultID := s.recordResult(req.UserID, prize)c.JSON(200, gin.H{"result_id": resultID,"prize":    prize,})
}

五、性能优化实战

1. 基准测试对比

func BenchmarkLottery(b *testing.B) {// 初始化100个奖品system := NewLotterySystem(genPrizes(100)) b.RunParallel(func(pb *testing.PB) {for pb.Next() {system.Draw("test_user")}})
}

优化前后性能对比：

优化措施	QPS	P99延迟
基础实现	12,000	45ms
加读写锁	9,800	68ms
用户粒度锁	28,000	22ms
Redis防重	18,000	35ms

2. 内存优化技巧

// 使用对象池减少GC压力
var prizePool = sync.Pool{New: func() interface{} {return new(Prize)},
}func getPrize() *Prize {p := prizePool.Get().(*Prize)p.Reset() // 重置字段return p
}func putPrize(p *Prize) {prizePool.Put(p)
}

六、生产环境建议

1. 监控指标配置

指标名称	类型	告警阈值
lottery_request_count	Counter	-
lottery_error_rate	Gauge	>5%持续5分钟
prize_stock_remaining	Gauge	<10%总库存
draw_duration_seconds	Histogram	P99>100ms

2. 灾备方案设计

七、扩展功能实现

1. 概率可视化验证

func TestProbabilityDistribution(t *testing.T) {system := NewLotterySystem(testPrizes)results := make(map[int]int)total := 1000000for i := 0; i < total; i++ {prize, _ := system.Draw()results[prize.ID]++}for id, count := range results {got := float64(count) / float64(total)want := float64(getPrizeWeight(id)) / float64(system.totalWeight)diff := math.Abs(got - want)if diff > 0.01 { // 允许1%误差t.Errorf("prize %d: got %.4f, want %.4f", id, got, want)}}
}

2. 奖品库存管理

type PrizeManager struct {redisClient *redis.Client
}// 使用Redis原子操作扣减库存
func (pm *PrizeManager) DeductStock(prizeID string) (bool, error) {script := `local key = KEYS[1]local stock = tonumber(redis.call("GET", key))if stock and stock > 0 thenreturn redis.call("DECR", key)elsereturn -1end`res, err := pm.redisClient.Eval(script, []string{"prize:" + prizeID}).Int()if err != nil {return false, err}return res >= 0, nil
}

八、项目部署方案

1. Docker Compose配置

version: '3'
services:lottery-api:image: lottery:1.0ports:- "8080:8080"depends_on:- redis- mysqlenvironment:- REDIS_ADDR=redis:6379- MYSQL_DSN=mysql://user:pass@mysql:3306/lotteryredis:image: redis:6-alpineports:- "6379:6379"volumes:- redis_data:/datamysql:image: mysql:8.0environment:- MYSQL_ROOT_PASSWORD=secret- MYSQL_DATABASE=lotteryvolumes:- mysql_data:/var/lib/mysqlvolumes:redis_data:mysql_data:

2. Kubernetes部署

apiVersion: apps/v1
kind: Deployment
metadata:name: lottery
spec:replicas: 3selector:matchLabels:app: lotterytemplate:metadata:labels:app: lotteryspec:containers:- name: lotteryimage: lottery:1.0ports:- containerPort: 8080resources:limits:cpu: "1"memory: "512Mi"readinessProbe:httpGet:path: /healthport: 8080initialDelaySeconds: 5periodSeconds: 10
---
apiVersion: v1
kind: Service
metadata:name: lottery
spec:selector:app: lotteryports:- protocol: TCPport: 80targetPort: 8080

九、总结与展望

通过本文我们实现了一个完整的权重抽奖系统，关键亮点包括：

精确的概率控制：基于区间算法实现准确权重分布
高并发安全：多级锁机制+Redis防重
生产级可用：监控、灾备、性能优化全套方案

未来扩展方向：

机器学习动态调权：根据活动效果自动调整奖品概率
区块链验证：抽奖结果上链提供公开验证
实时数据分析：用户行为分析与中奖预测

Go构建高并发权重抽奖系统：从设计到优化全流程指南

引言：为何需要专业抽奖系统？ 在现代互联网应用中，抽奖系统被广泛用于营销活动、用户激励等场景。一个好的抽奖系统需要满足： 公平性：确保概率分布准确高性能：支持高并发抽奖请求安全性：防止作…...

编程日记 2025/7/5 7:30:09

深度学习计算

深度学习的飞速发展离不开强大的计算能力支撑。从张量计算到 GPU 加速，从自动微分到分布式计算，深度学习计算的每一项技术都如同精密仪器中的关键齿轮，推动着模型性能的不断提升。本文深入剖析深度学习计算的核心技术、优化策略以及前沿趋势&…...

编程日记 2025/7/5 7:10:30

【Bluedroid】蓝牙 HID DEVICE 初始化流程源码解析

本文深入剖析Android蓝牙协议栈中HID设备（BT-HD）服务的初始化与启用流程，从接口初始化、服务掩码管理、服务请求路由到属性回调通知，完整展现蓝牙HID服务激活的技术路径。通过代码逻辑梳理，揭示服务启用的核心机制&…...

编程日记 2025/7/5 6:59:37

Kotlin 中的 Unit 类型的作用以及 Java 中 Void 的区别

在 Kotlin 中，Unit 类型和 Java 中的 void 关键字都用于表示“没有返回值”的函数，但它们在设计理念、类型系统和实际使用中有显著的区别。 1 Kotlin 中的 Unit 类型表示无返回值： 当函数不返回有意义的值时，Kotlin 使用 Unit …...

编程日记 2025/6/30 16:18:33

Gemini 2.5 推动视频理解进入新时代

每周跟踪AI热点新闻动向和震撼发展想要探索生成式人工智能的前沿进展吗？订阅我们的简报，深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同，从行业内部的深度分析和实用指南中受益。不要错过这个机会，成为AI领…...

编程日记 2025/6/29 8:43:48

Spark Streaming 内部运行机制详解

核心思想：将实时数据流切割为“微批次”，利用 Spark Core 的批处理能力进行准实时计算。 1. 核心流程拆解数据接收（Input Data Stream） 输入源：Kafka、Flume、Socket 等实时数据流。接收器（Receiver&…...

编程日记 2025/6/29 8:46:34

Feign+Resilience4j实现微服务熔断机制：原理与实战

引言：为什么需要熔断器？ 在微服务架构中，服务间的依赖调用变得非常普遍。想象一下这样的场景：订单服务依赖支付服务，支付服务又依赖银行网关服务。如果银行网关服务出现故障，故障会向上蔓延，导…...

编程日记 2025/6/29 1:23:04

什么是SparkONYarn模式

1. 什么是 Spark on YARN？ Spark on YARN 是 Apache Spark 的一种部署模式，允许 Spark 应用程序在 Hadoop YARN 集群上运行，充分利用 YARN 的资源管理和调度能力。这种模式将 Spark 与 Hadoop 生态深度集成，使企业能够在同一集群…...

编程日记 2025/6/29 0:39:55

鸿蒙北向应用开发: deveco5.0 创建开源鸿蒙项目

本地已经安装deveco5.0 使用5.0创建开源鸿蒙项目文件->新建->新建项目直接创建空项目,一路默认 next 直接编译项目直接连接开源鸿蒙5.0开发板编译会提示 compatibleSdkVersion and releaseType of the app do not match the apiVersion and releaseType on the dev…...

编程日记 2025/6/29 0:40:18

操作系统：内存管理

目录 1、主要目标 2、核心概念和技术 2.1 物理内存与虚拟内存 2.2 内存分页机制 2.3 页面置换算法 3、监控与性能优化 3.1 查看物理内存 3.2 查看虚拟内存 3.3 性能问题 1> 内存不足（OOM） 2> 内存泄漏 3> 内存碎片 3.4 性能优化策…...

编程日记 2025/6/29 1:23:29

腾讯优化DeepSeek的DeepEP通信框架：开启AI大模型训练新时代

事件背景在人工智能（AI）技术迅猛发展的当下，大规模AI模型训练的需求与日俱增。高效的数据通信成为了提升AI模型训练效率的关键环节。混合专家模型（MoE）作为一种高效的大模型架构，通过动态分配专家网络处理…...

编程日记 2025/6/28 23:09:14

CSP-J普及组第一轮真题单选题专项训练（二）

CSP-J普及组第一轮真题单选题专项训练（二） (共15题，每2分，共30分;每题有且有一个正确选项） 1、一个 32 位整型变量占用（）个字节。 A. 32 B. 128 C. 4 D. 8 2、在内存储器中每个存储单元都被赋予一个唯一的序号,称为 A、下标 B、序号 C、地址 D、编号 3、编译器的主要…...

编程日记 2025/6/28 23:42:45

Android加固工具测评：易盾、顶象、360加固哪款更好用？

应用安全已经成为每个开发者和企业关注的核心问题。随着黑客技术的不断升级，单一的安全措施已经无法有效应对各种复杂的攻击威胁。Android加固工具应运而生，成为了提升应用安全的关键利器。这些加固工具通过代码混淆、加密、防篡改等技术手段&#xff0c…...

编程日记 2025/6/29 1:19:40

C++ 字符格式化输出

文章目录一、简介二、实现代码三、实现效果一、简介这里使用std标准库简单实现一个字符格式化输出，方便后续的使用，它有点类似Qt中的QString操作。二、实现代码 FMTString.hpp #pragma once#include <cmath> #include <cstdio> #include…...

编程日记 2025/6/28 23:58:29

内存中的“BANK”

一、BANK的定义与物理结构基本概念 BANK（存储体） 是内存芯片内部的一个逻辑或物理分区，每个BANK由存储单元阵列、地址解码电路和缓冲器组成，用于分块管理内存操作。作用：通过并行操作减少访问冲突，提升内…...

编程日记 2025/6/29 1:28:42

D-Pointer（Pimpl）设计模式（指向实现的指针）

Qt 的 D-Pointer（Pimpl）设计模式 1. Pimpl 模式简介 Pimpl（Pointer to Implementation）是一种设计模式，用于将类的接口与实现分离，从而隐藏实现细节，降低编译依赖，提高代码的可维护…...

编程日记 2025/6/29 0:14:27

XA协议和Tcc

基于 XA 协议的两阶段提交 (2PC)。这是一种分布式事务协议，旨在保证在多个参与者（通常是不同的数据库或资源管理器）共同参与的事务中，所有参与者要么都提交事务，要么都回滚事务，从而维护数据的一致性。你…...

编程日记 2025/6/29 0:57:54

我们该如何使用DeepSeek帮我们减负？

在当今信息爆炸的时代，如何快速获取、筛选和分析信息已经成为各行各业的重要能力。而DeepSeek作为一种先进的智能搜索和信息挖掘工具，能够帮助用户快速找到所需的信息，并从海量数据中提取出有用的洞见。在这篇博文中，我们将深入探…...

编程日记 2025/6/29 1:32:12

25.5.13

感觉很久没有写算法题了，先来个滑动队列模板题试试水，就是用双端队列来实现会很方便，拿结构体来记录是第几个数和数的值即可，再定义两个双端队列，一个使他的值单调递增一个使他的值单调递减使队头元素为最大值或者是最…...

编程日记 2025/6/28 23:01:46

软件测试——面试八股文（入门篇）

今天给大家分享软件测试面试题入门篇，看看大家能答对几题一、请你说一说测试用例的边界参考回答： 边界值分析法就是对输入或输出的边界值进行测试的一种黑盒测试方法。通常边界值分析法是作为对等价类划分法的补充，这种情况下&#xff…...

编程日记 2025/6/29 0:38:56

脑机接口技术：开启人类与机器融合的新时代

摘要脑机接口（BCI）技术作为一项前沿科技，正在逐步打破人类与机器之间的沟通障碍，为医疗、娱乐、教育等多个领域带来前所未有的变革。本文将详细介绍脑机接口技术的基本原理、发展现状、应用场景以及面临的挑战和未来发展趋势&…...

编程日记 2025/6/28 23:51:49

当三维地理信息遇上气象预警：电网安全如何实现“先知先觉”？

极端天气频发的当下，一场台风、一次暴雨就可能让电力系统陷入瘫痪。但你知道吗？如今的电网已能通过三维地理信息与气象数据的深度融合，在灾害来临前精准锁定风险，甚至将停电事故减少七成以上。这背后，正是国网电力空间…...

编程日记 2025/6/29 0:06:34

C++ string数据查找、string数据替换、string子串获取

string查找示例见下，代码见下，以及对应运行结果见下： #include<iostream>using namespace std;int main() {// 1string s1 "hellooooworld";cout << s1.find("oooo") << endl;// 2cout << (in…...

编程日记 2025/6/29 0:54:55

2025.5.13山东大学软件学院计算机图形学期末考试回忆版本

2025.5.13山东大学软件学院计图期末考试回忆版本学院：软件学院老师：周元峰、魏广顺一、简述题（2024原题一） 1.图形绘制流水线的组成和作用 2.双缓冲机制是什么，有什么作用？ 3.Delaunay三角化的四条…...

编程日记 2025/6/28 23:29:10

思极地图使用

思极地图api文档：思极地图开放平台 | 思极地图API SDK 思极地图SDK: <script src"https://map.sgcc.com.cn/maps?v3.0.0"></script> <script src"https://map.sgcc.com.cn/products/js-sdk/v3/assets/js/jquery-1.11.1.min.js&quo…...

编程日记 2025/6/29 0:10:46

Fiori学习专题四十一：表单控件

上节课我们学习了一些单一控件的使用，但是我们发现在页面内每个控件都占用了一行，这样子就显得不太好看，这节课我们引入一个表单控件来美化一下这个页面。 1.学习表单控件FORM之前我们先了解下哪些情况会使用到表单控件，最常见的场…...

编程日记 2025/6/29 1:09:11

基于STM32、HAL库的TDA7719TR音频接口芯片驱动程序设计

一、简介： TDA7719TR 是 NXP Semiconductors 推出的高性能音频处理芯片，专为汽车音响系统设计。它集成了 AM/FM 收音机调谐器、音频处理和音量控制功能，支持 I2C 控制接口，非常适合与 STM32 微控制器配合使用。二、硬件接口：典型的 STM32L4 与 TDA7719TR 硬件连接如下…...

编程日记 2025/6/29 1:15:50

Baklib智能云平台加速企业数据治理

Baklib数据治理核心优势 Baklib作为新一代企业级知识中台，其数据治理能力建立在全资产统一管理与智能化处理框架的双重基础之上。通过构建知识中台的核心架构，平台实现了图文、音视频等多模态数据的标准化存储与动态标签体系，有效解决传统管…...

编程日记 2025/6/29 0:09:11

面试中被问到谈谈你对threadlocal的理解

ThreadLocal 的核心理解 1. 基本概念 ThreadLocal 是 Java 提供的线程局部变量机制，用于在多线程环境中为每个线程维护独立的变量副本，实现线程隔离。其核心思想是空间换时间，通过避免共享变量带来的同步开销，提升并发性能。 2…...

编程日记 2025/6/28 23:01:06

Spring Boot 应用中实现基本的 SSE 功能

SSE 技术简介 SSE（Server-Sent Events）是一种允许服务器主动向客户端推送数据的技术。它基于 HTTP 长连接，使用简单，特别适合实时数据更新场景，如股票行情、新闻推送等。与 WebSocket 相比，SSE 更轻量级&a…...

编程日记 2025/6/28 23:46:58

【2025最新】Windows系统装VSCode搭建C/C++开发环境（附带所有安装包）

文章目录为什么选择VSCode作为C/C开发工具？一、VSCode安装过程（超简单！）二、VSCode中文界面设置（再也不用对着英文发愁！）三、安装C/C插件（编程必备神器！）四、…...

编程日记 2025/6/29 0:18:13

【MyBatis-8】MyBatis对象关联查询详解：高效处理复杂关系映射

在实际业务开发中，我们经常需要处理对象之间的关联关系，如一对一、一对多、多对多等。MyBatis作为一款优秀的持久层框架，提供了强大的对象关联查询能力。本文将深入探讨MyBatis中各种关联查询的实现方式、适用场景及最佳实践。 1. MyBatis关…...

编程日记 2025/6/28 23:34:19

Java基础(IO)

所有操作都在内存，不能长时间保存，IO主要在硬盘，可以长时间保存。一、File类 File类被定义为文件和目录路径名的抽象表示形式，这是因为 File 类既可以表示文件也可以表示目录，他们都通过对应的路径来描述。提供构…...

编程日记 2025/6/28 23:34:10

Trae IDE：AI深度集成的智能开发环境

（以高效人机协作重塑编程体验） 概述 Trae IDE（发音 /treɪ/）是一款深度集成AI能力的现代化开发工具，结合传统IDE的完备功能与前沿AI技术，提供智能问答、代码自动补全、跨文件编程及AI Agent驱动的自动化开…...

编程日记 2025/6/29 0:40:52

网站开发过程中样式忽然不显示问题

老规矩，先听故事：今天我开发网站时候遇到一个问题，就开发的这个网站在默认127.0.0.1运行样式有bug显示不出来，之前都可以，就完全一样的代码，之前可以正常运行显示，今天忽然就不行了，…...

编程日记 2025/6/28 23:02:31

双种群进化算法：动态约束处理与资源分配解决约束多目标优化问题

双种群进化算法：动态约束处理与资源分配解决约束多目标优化问题一、引言约束多目标优化问题（CMOPs）在工程设计、资源分配等领域广泛存在，其核心是在满足多个约束条件的同时优化多个目标函数。传统方法往往难以平衡约束满足与目…...

编程日记 2025/6/29 0:03:07

如何在 CentOS 7 虚拟机上配置静态 IP 地址并保持重启后 SSH 连接

在使用 CentOS 7 的虚拟机时，我们通常需要配置静态 IP 地址，以确保在每次虚拟机重启后能够通过 SSH 连接。本文将介绍如何在 CentOS 7 系统中配置静态 IP 地址，并确保配置在系统重启后依然生效。步骤 1：检查虚拟机网络接口首先…...

编程日记 2025/6/28 23:02:35

整数和浮点数转换时的精度损失

文章目录 int和float转换时的精度损失float组成解析（1） 32位浮点数的结构（2）示例：解析一个浮点数（3）偏置值的作用（4） 偏置值为什么是127？（5&#…...

编程日记 2025/6/28 23:02:30

Protobuf工具

#region 知识点一什么是 Protobuf //Protobuf 全称是 protocol - buffers（协议缓冲区） // 是谷歌提供给开发者的一个开源的协议生成工具 // 它的主要工作原理和我们之前做的自定义协议工具类似 // 只不过它更加的完善&…...

编程日记 2025/6/29 0:24:23

闭包原理与常见陷阱

引言 JavaScript闭包是前端开发中既强大又神秘的概念，它不仅是面试的必考题，更是解决复杂问题的利器。闭包让函数能够记住并访问其创建时的作用域，即使在该函数在其定义环境之外执行。然而，正如许多强大的工具一样，…...

编程日记 2025/6/29 0:41:04

用 VS Code / PyCharm 编写你的第一个 Python 程序

用ChatGPT做软件测试编写你的第一个 Python 程序——不只是“Hello, World”，而是构建认知、习惯与未来的起点 “第一行代码，是一个开发者认知世界的方式。” 编程的入门，不只是运行一个字符串输出，更是开始用计算机思维来理解、…...

编程日记 2025/6/29 1:27:07

Linux学习心得问题整理（一）

day01 运维初识理解云计算运维目的是什么？ 搭建云计算更有利于我们在公网环境下方便访问我们服务节省时间的成本，能随时随地方便调度硬件资源，更容易搭建软件服务安全可靠，售后期间支持技术支持维护什么是运维&#xff1f…...

编程日记 2025/6/29 0:34:27

在scala中sparkSQL连接masql并添加新数据

以下是 Scala 中使用 Spark SQL 连接 MySQL 并添加数据的完整代码示例（纯文本）： 1. 准备连接参数（需替换实际信息） scala val jdbcUrl "jdbc:mysql://localhost:3306/test_db?useUnicodetrue&characterEnc…...

编程日记 2025/6/28 23:01:17

STM32F103_LL库+寄存器学习笔记22 - 基础定时器TIM实现1ms周期回调

导言如上所示，STM32F103有两个基本定时器TIM6与TIM7，所谓「基本定时器」，即功能最简单的定时器。项目地址： github: LL库: https://github.com/q164129345/MCU_Develop/tree/main/stm32f103_ll_library22_Basic_Timer寄存器方…...

编程日记 2025/6/28 23:37:44

.Net HttpClient 使用Json数据

HttpClient 使用Json数据现代Web项目中，Json是最常用的数据格式。不论是前后端的交互中，还是纯前端项目中，都是如此。因此，.Net HttpClient 能不能更加方便、快捷的处理Json格式数据，也就至关重要了！ 文末…...

编程日记 2025/6/29 0:01:34

AI时代，如何实现人机共舞？

在科技飞速发展的当下，人工智能（AI）已不再是科幻作品中的遥远想象，而是深入渗透到我们生活与工作的方方面面。从智能手机中的语音助手，到金融领域的风险预测模型；从医疗影像的智能诊断，到工业生…...

编程日记 2025/6/28 23:42:55

flea-cache使用之Redis哨兵模式接入

Redis哨兵模式接入 1. 参考2. 依赖3. 基础接入3.1 定义Flea缓存接口3.2 定义抽象Flea缓存类3.3 定义Redis客户端接口类3.4 定义Redis客户端命令行3.5 定义哨兵模式Redis客户端实现类3.6 定义Redis哨兵连接池3.7 定义Redis哨兵配置文件3.8 定义Redis Flea缓存类3.9 定义抽象Flea…...

编程日记 2025/6/29 1:21:06

【Docker】Docker环境下快速部署Ollama与Open-WebUI：详细指南

Docker环境下快速部署Ollama与Open-WebUI：详细指南在本篇文章中，我们将深入探讨如何在Docker中高效部署 Ollama 和 Open-WebUI，并解决在实际使用中常见的问题，确保你的模型服务稳定高效地运行。一、Ollama 和 Open-WebUI 快速部…...

编程日记 2025/6/29 1:21:11

FFmpeg在Android开发中的核心价值是什么？

FFmpeg 在 Android 开发中的核心价值主要体现在其强大的多媒体处理能力和灵活性上，尤其在音视频编解码、流媒体处理及跨平台兼容性方面具有不可替代的作用。以下是具体分析： --- 1. 强大的音视频编解码能力 - 支持广泛格式：FFmpeg 支持几乎所…...

编程日记 2025/6/28 23:19:12

Java的进制转换

进制知识 Java 中使用不同的前缀表示数据，常见的进制数据有二进制（0b）、八进制（0）、十进制（无）、十六进制（0x）。 public class Demo1 {public static void main(String…...

编程日记 2025/6/28 23:01:19