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

Go有限状态机实现和实战

news 来源：原创 2025/6/24 16:14:25

Go有限状态机实现和实战

在这里插入图片描述

有限状态机

什么是状态机

有限状态机（Finite State Machine, FSM）是一种用于建模系统行为的计算模型，它包含有限数量的状态，并通过事件或条件实现状态之间的转换。FSM的状态数量是有限的，因此称为有限状态机

关于有限的解释：也就是被描述的事物的状态的数量是有限的，例如开关的状态只有“开”和“关”两个;灯的状态只有“亮”和“灭”等等。

特点

状态机的状态数量是有限的,在确定的状态下，给定特定的事件，系统会转换到明确的下一个状态。

作用

使用状态机来表达状态的流转，会使语义会更加清晰，会增强代码的稳定性、可控性和可维护性。

适用场景

面对复杂的状态流转都可以使用状态机来实现

状态机是描述系统行为的强大工具，其核心是状态、事件和状态转换。它的清晰逻辑和确定性使其在复杂流程控制、嵌入式设备、游戏开发等领域非常适用，为系统开发提供了简洁、高效的解决方案。

状态机核心概念

状态机有四个核心概念，这是所有状态机的基础

State：状态。一个状态机至少要包含两个状态。
Transition：过渡。也就是从一个状态变化为另一个状态（即状态转移）。
Event：事件。事件会触发状态转移，也就是状态转移的条件。
Action：动作。事件发生以后要执行动作，即事件处理。

有限状态机的工作原理如图所示，发生事件(event)后，根据当前状态(cur_state) ，决定执行的动作(action)，并设置下一个状态(next_state)。

Go状态机设计

我们根据上面的概念设计一个状态机

示例：自动贩卖机状态机

在这里插入图片描述

package mainimport ("fmt"
)// 定义状态类型
type State string
//  1.State：状态。一个状态机至少要包含两个状态。
const (StateIdle     State = "Idle(空闲)"     // 空闲状态StateCoin     State = "Coin(投币)"     // 投币状态StateItem     State = "Item(选择商品)"     // 选择商品状态
)// 定义事件类型
type Event string
// 2.Event：事件。事件会触发状态转移，也就是状态转移的条件。
const (EventInsertCoin  Event = "InsertCoin"  // 投币事件EventSelectItem  Event = "SelectItem"  // 选择商品事件EventDispense    Event = "Dispense"    // 出货事件
)// 定义状态转移 
// 3.Transition：过渡。也就是从一个状态变化为另一个状态（即状态转移）。
const(Transitions = map[State]map[Event]State{StateIdle: {EventInsertCoin: StateCoin,},StateCoin: {EventSelectItem: StateItem,},StateItem: {EventDispense: StateIdle,},}
)// 定义状态机结构体
type FSM struct {currentState Statetransitions  map[State]map[Event]State // 状态-事件转换映射
}
// 创建状态机
func NewFSM() *FSM {return &FSM{currentState: StateIdle, // 初始状态transitions: Transitions,}
}// 处理事件并进行状态转换
// 4.Action：动作。事件发生以后要执行动作，即事件处理。
func (fsm *FSM) HandleEvent(event Event) {nextState, ok := fsm.transitions[fsm.currentState][event]if !ok {fmt.Printf("事件 %s 无法从状态 %s 转换\n", event, fsm.currentState)return}fmt.Printf("从状态 %s 转到状态 %s 通过事件 %s\n", fsm.currentState, nextState, event)fsm.currentState = nextState
}// 获取当前状态
func (fsm *FSM) CurrentState() State {return fsm.currentState
}func main() {fsm := NewFSM()// 测试状态机fsm.HandleEvent(EventInsertCoin)  // 投币，进入选择商品状态fsm.HandleEvent(EventSelectItem)  // 选择商品，准备出货fsm.HandleEvent(EventDispense)    // 出货，返回初始状态
}

运行结果

从状态 Idle(空闲) 转到状态 Coin(投币) 通过事件 InsertCoin(投币事件)
从状态 Coin(投币) 转到状态 Item(选择商品) 通过事件 SelectItem(选择商品事件)
从状态 Item(选择商品) 转到状态 Idle(空闲) 通过事件 Dispense(出货事件)

代码解释:

State(对应State) ：定义了有限状态机的状态和事件。状态有 Idle、Coin、Item 和 Dispense。
Event(对应Event)：事件有 InsertCoin、SelectItem、Dispense 和 ReturnCoins。
Transitions(对应Transition)：定义了状态转移规则，即当某个状态收到某个事件时，会转移到另一个状态。
HandleEvent(对应Action)：该方法处理事件，并根据当前状态和事件查找下一个状态。如果找不到对应的转换，则表示事件在当前状态下无效。
FSM 结构体：负责存在状态机的信息，FSM 包含当前状态和状态转换规则。transitions 映射定义了每个状态在不同事件下的下一个状态。

事件处理

我们可以将Action进行拓展，对状态机进行扩展，比如添加日志记录、超时处理、错误处理、通知等。
在这里插入图片描述
具体实现我们可以参考下面生产使用的代码。

生产使用

上面的代码是一个简单的状态机，实际使用中，需要考虑更多的因素，比如状态的初始化、状态的持久化、状态的恢复、状态的监听等。

状态的初始化：在创建状态机时，需要初始化当前状态，并设置初始状态的转换规则。
状态的持久化：在状态机中，需要将状态的转换记录持久化到数据库或者文件中，以便在系统重启时恢复状态。
状态的恢复：在系统重启时，需要根据持久化的状态记录恢复状态机。
状态的监听：在状态机中，需要监听状态的变化，以便在状态发生变化时进行通知。
状态的校验：在状态机中，需要校验状态的转换是否合法，比如不允许从空闲状态直接进入选择商品状态。
状态的错误处理：在状态机中，需要处理状态转换过程中出现的错误，比如转换失败、超时等。
状态的日志记录：在状态机中，需要记录状态的转换记录，以便后续分析

…

生产上我们可以使用 github.com/looplab/fsm
这个库提供了一些常用的功能，如状态的初始化、状态的持久化、状态的恢复、状态的监听等。

package fsm_demoimport ("context""fmt""testing""github.com/looplab/fsm"
)// 定义状态类型
type State string// 1.State：状态。一个状态机至少要包含两个状态。
const (StateIdle State = "Idle(空闲)"   // 空闲状态StateCoin State = "Coin(投币)"   // 投币状态StateItem State = "Item(选择商品)" // 选择商品状态
)// 定义事件类型
type Event string// 2. Event：事件。事件会触发状态转移，也就是状态转移的条件。
const (EventInsertCoin Event = "InsertCoin" // 投币事件EventSelectItem Event = "SelectItem" // 选择商品事件EventDispense   Event = "Dispense"   // 出货事件
)type FSM struct {Id  string   // 数据idFSM *fsm.FSM // 状态机
}func NewFSM(id string) *FSM {d := &FSM{Id: id,}d.FSM = fsm.NewFSM(string(StateIdle),// 3. Transition 定义转换fsm.Events{{Name: string(EventInsertCoin), Src: []string{string(StateIdle)}, Dst: string(StateCoin)},{Name: string(EventSelectItem), Src: []string{string(StateCoin)}, Dst: string(StateItem)},{Name: string(EventDispense), Src: []string{string(StateItem)}, Dst: string(StateIdle)},},// 4. Action 定义动作fsm.Callbacks{"before_event": func(ctx context.Context, e *fsm.Event) {fmt.Println(e.Args[0])e.FSM.SetMetadata("error", "error")fmt.Println("before_event 通用（可以记录日志）", e.Event, e.FSM.Current())e.Err = fmt.Errorf("error")e.Cancel()// e.Event = "error"},fmt.Sprintf("before_%s", EventInsertCoin): func(ctx context.Context, e *fsm.Event) {fmt.Println("before", EventInsertCoin, e.Event, e.FSM.Current())// e.Err = fmt.Errorf("error")},fmt.Sprintf("enter_%s", StateCoin): func(ctx context.Context, e *fsm.Event) {fmt.Println("enter", StateCoin, e.Event, e.FSM.Current())// e.Err = fmt.Errorf("error")},"enter_state": func(_ context.Context, e *fsm.Event) { d.enterState(e) },fmt.Sprintf("after_%s", EventInsertCoin): func(ctx context.Context, e *fsm.Event) {fmt.Println("after", EventInsertCoin, e.Event, e.FSM.Current())// e.Err = fmt.Errorf("error")},"after_event": func(_ context.Context, e *fsm.Event) {fmt.Println(e.FSM.Metadata("error"))fmt.Println("after_event 通用(可以记录日志)", e.Event, e.FSM.Current())},},)return d
}// 更新状态
func (d *FSM) enterState(e *fsm.Event) {// called after entering all states// todo 更新数据库,持久化fmt.Println("enter_state 通用 更新数据库", e.FSM.Current())
}func Test_Main(t *testing.T) {plan := NewFSM(string(StateIdle))err := plan.FSM.Event(context.Background(), string(EventInsertCoin), 1)if err != nil {fmt.Println(err)}fmt.Println(plan.FSM.Current())err = plan.FSM.Event(context.Background(), string(EventSelectItem))if err != nil {fmt.Println(err)}fmt.Println(plan.FSM.Current())err = plan.FSM.Event(context.Background(), string(EventDispense))if err != nil {fmt.Println(err)}fmt.Println(plan.FSM.Current())err = plan.FSM.Event(context.Background(), string(EventDispense))if err != nil {fmt.Println(err)}fmt.Println(plan.FSM.Current())
}

使用去起来和我们自己写的代码类似，也是定义 State ,Evnent,Transition,Action。这个是所有FSM通用的。

这个库可以很灵活的配置事件处理。可以配置很多前置和后置事件。

// 1. before_<EVENT> - 在名为 <EVENT> 的事件之前调用
// 2. before_event - 在所有事件之前调用
// 3. leave_<OLD_STATE> - 在离开 <OLD_STATE> 之前调用
// 4. leave_state - 在离开所有状态之前调用
// 5. enter_<NEW_STATE> - 在进入 <NEW_STATE> 之后调用
// 6. enter_state - 在进入所有状态之后调用
// 7. after_<EVENT> - 在名为 <EVENT> 的事件之后调用
// 8. after_event - 在所有事件之后调用

而且错误处理机制也很完善。使用这个库后大家可以把更多的精力关注业务层。

参考:

https://github.com/looplab/fsm

https://www.cnblogs.com/huageyiyangdewo/p/17351310.html

Go有限状态机实现和实战

Go有限状态机实现和实战有限状态机什么是状态机有限状态机（Finite State Machine, FSM）是一种用于建模系统行为的计算模型，它包含有限数量的状态，并通过事件或条件实现状态之间的转换。FSM的状态数量是有限的，因此称…...

编程日记 2025/6/24 16:14:25

使用torch模型BMM int8计算。模拟：BMM->softmax->BMM 计算流程 import torch import numpy as np torch.manual_seed(777) def int8_quantize_per_token(x: torch.Tensor, axis: int -1, attnsFalse):if x.dtype ! torch.float32:x x.type(torch.float32)…...

编程日记 2025/5/30 22:45:21

vue3的watch一次性监听多个值用法

vue3的watch一次性监听多个值 1、监听单个值 watch(() > route.params.keyword, (newValue, oldValue) > {console.log(监听值变化, newVal, oldVal)state.a newValue});2、监听多个值 watch(() > [route.params.id, route.params.keyword], (newValue, oldValue) &g…...

编程日记 2025/6/20 18:03:41

【one-api和ollama结合使用】

将Ollama接入one-api one-api是一个开源AI中间件服务，可以聚合各家大模型API，比如OpenAI、ChatGLM、文心一言等，聚合后提供统一的OpenAI调用方法。举个例子：ChatGLM和文心一言的API调用方法并不相同，one-api可以对其进…...

编程日记 2025/6/21 21:07:45

Oracle PDB的开启和关闭

[生产环境关闭与开启Oracle PDB] 【运维场景】在运维Oracle PDB的时候经常要开启和关闭PDB，对关闭和开启PDB的操作要非常熟悉。【操作方法】 1. PDB的打开与关闭关闭和开启DB的时候要看DB的警告日志，日志位置（在Oracle用户下查看&…...

编程日记 2025/5/30 6:46:11

十一、动态构建UI元素

装饰器Builder 装饰器BuilderParam <font style"color:rgba(0, 0, 0, 0.9);">BuilderParam</font> 该装饰器用于声明任意UI描述的一个元素，类似slot占位符。链接简而言之：就是自定义组件允许外部传递 UI // SonCom 的实现略…...

编程日记 2025/6/24 14:32:42

智能时代的基石：神经网络

智能时代的基石：神经网络第一节：神经网络简介课程目标本节课程旨在全面介绍神经网络的基本概念、结构以及其在历史发展中的重要里程碑。通过深入理解神经网络的工作原理和演变过程，学员将能够掌握神经网络在现实世界中的多种应用&#…...

编程日记 2025/6/23 8:54:55

VScode配置GIT

在Visual Studio Code（VSCode）中检测不到已安装的Git可以通过以下步骤来解决‌： ‌确认Git是否正确安装‌：首先，确保在计算机上正确安装了Git。可以通过打开命令行窗口并输入git --version来检查是否能够显示Git的版本…...

编程日记 2025/6/19 23:10:36

【CSS】css 如何实现固定宽高比

今天和同事讨论这个问题，一时间还想不到了，于是学习了下，就顺便当个记录吧要在CSS中实现固定宽高比，有两种主要的方法可以选择。一种是使用新的aspect-ratio属性，另一种是利用padding技巧。随着现代浏览器对aspect-ra…...

编程日记 2025/6/20 20:41:04

使用webrtc-streamer查看实时监控

摄像头配置（海康摄像头为例） 摄像头视频编码应改成H264格式 webrtc-streamer下载 webrtc-streamer下载地址下载后解压出来双击运行，端口默认8000 VUE2项目引入文件在项目静态文件“public”中需引入两个js文件“webrtcstreamer.js”与“…...

编程日记 2025/6/24 15:21:37

ansible部署nginx：1个简单的playbook脚本

文章目录 hosts--ventoryroles执行命令使用ansible向3台centos7服务器上安装nginx hosts–ventory [rootstand playhook1]# cat /root/HOSTS # /root/HOSTS [webservers] 192.168.196.111 ansible_ssh_passpassword 192.168.196.112 ansible_ssh_passpassword 192.168.196.1…...

编程日记 2025/5/30 16:57:05

Ubuntu安装Gitlab详细图文教程

1、环境准备 1.1、Ubuntu环境 Ubuntu24.04Sever版安装教程 1.2、更新系统 sudo apt update -y sudo apt-get update sudo apt-get upgrade 2、安装Nginx 2.1 安装nginx # 安装 apt install nginx -y 2.2 修改nginx配置⽂件 # 修改nginx配置 vim /etc/nginx/si…...

编程日记 2025/6/24 15:40:12

前端面试准备问题2

1.防抖和节流分别是什么，应用场景防抖：在事件被触发后，只有在指定的延迟时间内没有再次触发，才执行事件处理函数。在我的理解中，简单的说就是在一个指定的时间内，仅触发一次，如果有多次重复触…...

编程日记 2025/6/23 14:22:33

uni-app之web-view组件 postMessage 通信【跨端开发系列】

🔗 uniapp 跨端开发系列文章：🎀🎀🎀 uni-app 组成和跨端原理【跨端开发系列】 uni-app 各端差异注意事项【跨端开发系列】uni-app 离线本地存储方案【跨端开发系列】uni-app UI库、框架、组件选型指南【跨端开…...

编程日记 2025/6/24 10:55:07

IntelliJ IDEA 使用技巧与插件推荐

目录常用使用技巧 1. 使用快捷键提升开发效率 2. 多光标编辑 3. 代码自动补全 4. 使用 Find Action 快速执行操作 5. 集成版本控制系统（VCS） 6. 快速查看代码文档推荐插件 1. Lombok Plugin 2. Rainbow Brackets 3. Key Promoter X 4. Chec…...

编程日记 2025/6/24 15:46:25

zookeeper基础命令详解

zookeeper基础命令详解目录文章目录 zookeeper基础命令详解目录一、列出所有基础命令一、列出所有基础命令先启动一个zookeeper客户端连接zookeeper，如果还没有启动zookeeper集群的参考本文启动之后再做后续操作。 https://blog.csdn.net/weixin_42924400/artic…...

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

2025周易算命网站搭建详细方法+源码选择php环境的配置

以下是一个详细的搭建教程，包括网站分类、环境配置、程序设计和功能实现。 1. 环境准备 1.1 服务器选择操作系统: Linux（推荐使用Ubuntu或CentOS）Web服务器: Nginx数据库: MySQLPHP版本: 7.4.x（确保小于8.0） 1.2 安…...

编程日记 2025/6/21 1:41:03

16：00面试，16：06就出来了，问的问题有点变态。。。

从小厂出来，没想到在另一家公司又寄了。到这家公司开始上班，加班是每天必不可少的，看在钱给的比较多的份上，就不太计较了。没想到5月一纸通知，所有人不准加班，加班费不仅没有了，薪资还要降40%…...

编程日记 2025/6/24 16:11:44

《杨辉三角》

题目描述给出 n(1≤n≤20)n(1≤n≤20)，输出杨辉三角的前 nn 行。如果你不知道什么是杨辉三角，可以观察样例找找规律。输入格式无输出格式无输入输出样例输入 #1复制 6 输出 #1复制 1 1 1 1 2 1 1 3 3 1 1 4 6 4 1 1 5 10 10 5 1 C语言…...

编程日记 2025/5/31 0:37:45

2024年03月中国电子学会青少年软件编程（Python）等级考试试卷（五级）答案 + 解析

青少年软件编程（Python）等级考试试卷（五级）分数：100 题数：38 一、单选题(共25题，共50分) 1. 以下代码的输出结果是？（） nums = list(range(100, 201)) print...

编程日记 2025/5/27 0:33:12

【游戏设计原理】7 - 加德纳的多元智能理论

虽然多元智能理论是对认知方式的分类，但它也可以为游戏设计提供丰富的思路和策略，帮助设计师创建更具吸引力、包容性和多样性的游戏。通过理解不同玩家的认知方式和优势，我们可以更精准地设计游戏的元素和玩法，使其能够吸引广泛的…...

编程日记 2025/6/22 1:40:17

Jackson @JsonProperty 注解

1. 概述 Jackson 是一个流行的Java库，用于将Java对象转换为JSON格式以及从JSON反序列化回Java对象。一种常见的需求是在序列化为JSON或从JSON反序列化时自定义字段的命名。Jackson 的 JsonProperty 注解正好满足了这一需求。 JsonProperty 注解概览 JsonProperty…...

编程日记 2025/6/1 10:22:31

【数据结构——栈与队列】链栈的基本运算（头歌实践教学平台习题）【合集】

目录😋 任务描述相关知识测试说明我的通关代码: 测试结果： 任务描述本关任务：编写一个程序实现链栈的基本运算。相关知识为了完成本关任务，你需要掌握： 初始化栈、销毁栈、判断栈是否为空、进栈、出栈、取栈…...

编程日记 2025/6/4 4:01:22

数据库乐观锁和悲观锁、redis分布式锁使用场景

前言最近发现我们同事，但凡需要加锁的地方都用的是分布式锁。而且我们的后台系统，并没有什么并发量，而且还是单体应用。我真的有点怀疑我的同事不太清楚数据乐观锁、悲观锁和redis分布式的使用场景。请今天就说一下各种锁的应用场景吧。 …...

编程日记 2025/6/23 8:27:58

React的状态管理库-Redux

核心思想：单一数据源、状态是只读的、以及使用纯函数更新状态。组成部分 Store（存储） 应用的唯一状态容器，存储整个应用的状态树,使用 createStore() 创建。 getState()：获取当前状态。dispatch(action)&#xff…...

编程日记 2025/6/24 8:22:55

《自制编译器》--青木峰郎 -读书笔记编译hello

在该书刚开始编译hello.cb时就遇到了问题。本人用的是wsl，环境如下， 由于是64位，因此根据书中的提示，从git上下载了64位的cb编译器 cbc-64bit 问题一: 通过如下命令编译时,总是报错。 cbc -Wa,"--32" -Wl,"-…...

编程日记 2025/6/24 16:10:42

XSS（跨站攻击）

XSS漏洞（跨站脚本） 1.XSS 漏洞简介 XSS又叫CSS（Cross Site Script）跨站脚本攻击是指恶意攻击者往Web页面里插入恶意Script代码，当用户浏览该页之时，嵌入其中Web里面的Script代码会被执行，从…...

编程日记 2025/6/21 1:41:01

华为自反ACL实验

一、实验背景做这个实验的原因是最近公司里上了三台小程序服务器，由于三台服务器的端口都映射出去了，领导要求A网段的三台服务器不能访问内网B，C网段，同时B、C网段内网用户可以访问A段的94、95、96服务器； 也就是PC4\…...

编程日记 2025/6/24 15:20:13

MyBatisPlus实现多表查询

在MyBatisPlus中实现多表查询，主要有以下几种方法： 使用注解进行多表查询： 你可以在Mapper接口中使用Select注解来编写SQL查询语句，实现多表查询。例如，如果你想根据用户ID查询用户信息和对应的区域名称，可…...

编程日记 2025/6/19 20:20:16

【人工智能-中级】循环神经网络（RNN）与Transformer在自然语言处理中的进阶应用

循环神经网络（RNN）与Transformer在自然语言处理中的进阶应用自然语言处理（NLP）是人工智能领域中的重要分支，其主要任务是使计算机能够理解、生成和处理人类语言。近年来，循环神经网络（RNN）和Transformer模型已成为NLP领域的两大核心技术。本文将探讨这两类模型在自然…...

编程日记 2025/6/24 5:45:39

ZED相机应用

下载SDK wget https://stereolabs.sfo2.cdn.digitaloceanspaces.com/zedsdk/3.6/ZED_SDK_Ubuntu18_cuda11.5_v3.6.5.run 安装 ./ZED_SDK_Ubuntu18_cuda11.5_v3.6.5.run skip_python 测试 cd /usr/local/zed/tools ls ZED_Calibration ZED_Depth_Viewer ZED_Diagnostic ZED_E…...

编程日记 2025/6/24 15:56:01

Go有限状态机实现和实战

有限状态机

状态机核心概念

Go状态机设计

示例：自动贩卖机状态机

事件处理

生产使用

相关文章：