产者 消费者 模式golang
【转】SpringBoot实现策略模式
文章来源： 微信公众号 《Java极客技术》 ，作者：鸭血粉丝Tang 1. 普通代码实现 在介绍 SpringBoot 中如何实现策略设计模式之前，我们先简单的回顾一下策略模式的设计思路。以编写一个简单的程序计算器，代码如下！ 首先，我们定义一个Operation接口，用于逻辑的计算 public ......
go设计模式之工厂模式
Go语言实现设计模式之工厂方法模式 原创 汀风 汀风说后端 2023-12-06 08:10 发表于北京 汀风说后端 编程知识普及，让学习与工作变得更简单。 18篇原创内容 公众号 摘要： 工厂方法模式是一种创建型设计模式，它将对象的创建延迟到子类中进行，通过定义一个创建对象的接口，让子类决定实例化 ......
Golang（Go语言） 对windows进行注销、关机、重启、闪电关机、闪电重启的操作
有个小项目需要对windows系统进行远程电源操作，于是封装了以下代码方便使用。 目录结构如下： main.go package main import ( "fastshutdown/utils/power" "fmt" ) func main() { err := power.Shutdown( ......
kafka入门(三)：kafka多线程消费
kafka消费积压 如果生产者发送消息的速度过快，或者是消费者处理消息的速度太慢，那么就会有越来越多的消息无法及时消费，也就是消费积压。 消费积压时，可以使用多线程消费，提高消费速度。 kafka多线程消费的代码： public class ThirdMultiConsumerThreadDemo ......
使用分布式事务 Seata 的 TCC 模式
Seata 的 TCC 模式需要通过人工编码来实现数据的回滚恢复，有点麻烦，但是性能最高。TCC 是 3 个方法的首字母缩写，即 Try 方法、Confirm 方法、Cancel 方法。Try 方法进行资源的检查和冻结，Confirm 方法是当所有事务都成功后调用的方法，Cancel 方法是当整体事 ......
控制文件读写内容的模式
控制文本读写格式 t（默认的）：文本模式 读写都是以字符串的为单位的 只能针对文本文件 必须加入encoding参数 b：二进制模式 读写文件都是以bytes/二进制为单位 可以针对所有的文件 不可以加入encoding参数 前提： b / t模式都不能单独使用，必须与r / w / a之一结合使用 ......
控制文本读写内容的模式
控制文本读写格式 t（默认的）：文本模式 读写都是以字符串的为单位的 只能针对文本文件 必须加入encoding参数 b：二进制模式 读写文件都是以bytes/二进制为单位 可以针对所有的文件 不可以加入encoding参数 前提： b / t模式都不能单独使用，必须与r / w / a之一结合使用 ......
golang的蓝牙通信库
github.com/tinygo-org/bluetooth： TinyGo是一个Go语言编译器，它专注于微控制器和小型计算机系统。这个库是TinyGo项目的一部分，用于支持蓝牙低功耗（BLE）设备。 github.com/go-ble/ble： 这是一个轻量级的Golang库，旨在简化与蓝牙低功 ......
《软件需求模式》阅读笔记01
软件需求这门课课程要求精读一门关于软件需求方面的书，我选择了《软件需求模式》这本书，从这本书来了解一下软件需求的一些流程以及需要软件工作人员做好那些事情。 第1章主要介绍了什么是需求以及我们应该如何去得到他们。 需求的概念：定义系统需要做什么，而不是怎么去做。我的理解就是在需求时，我们不需要考虑怎么 ......
车企数据治理实践案例，实现数据生产、消费的闭环链路 | 数字化标杆
随着业务飞速发展，某汽车制造企业业务系统数量、复杂度和数据量都在呈几何级数的上涨，这就对于企业IT能力和IT架构模式的要求越来越高。加之企业大力发展数字化营销、新能源车等业务，希望通过持续优化客户体验，创造可持续发展的数字化转型之路。 为更好应对数字化变革所带来的挑战，现有的竖井架构的数据体系难以满 ......
golang之媒体处理
[视频] 获取视频封面图: 1) 如果是使用oss的话, 可以添加指定的后缀生成指定图片 获取视频长度: 1)若是oss上的视频,则可以使用阿里云的IMM中的提取视频信息的服务 注意这里获取需要使用到签名之后获取对应的数据 这里使用基于阿里云oss包: github.com/aliyun/aliyu ......
设计模式之享元模式
1. 定义 共享多个对象所共有的相同状态，以节省内存和提高性能 2. 口语化举例 现有一台灯工厂，有五个生产线（分别生产五种产品）、两个销售部门 这两销售部门在销售产品出去后，都会直接去找生产线生产，有时两部门同时销售出同一种产品，导致这个产品的生产线繁忙 现在，工厂提出一种新方法： 每个生产线都会 ......
使用分布式事务 Seata 的 AT 模式
有了上篇博客实现 XA 模式的基础，本篇博客在实现 AT 模式时，不需要修改任何代码，只需要增加一张数据库表，修改以下 application.yml 配置即可实现。AT 模式也是分两个阶段提交的事务模型，它缺弥补了 XA 模型中资源锁定周期过长的问题。 其实现的两个阶段的工作原理如下： 第一阶段注 ......
GOF23--23种设计模式（一）
一.什么是设计模式 设计模式（Design Pattern）是前辈们对代码开发经验的总结，是解决一系列特定问题的套路。 它不是语法规定，而是一套用来提高代码复用性，可读性，可维护性，稳健性，安全性的解决方案 设计模式的雏形： 1995年，GOF（Gang of Four，四人/四人帮）合作出版了《设 ......
并发设计模式
1. 不可变模式 2. 写时复制模式 3. 线程本地存储模式 4. Guarded Suspension模式 5. Balking模式 6. Thread-Per-Message模式 7. Worker Thread模式 8. 两阶段终止模式 9. 生产者-消费者模式 ......
处理golang gin框架下载文件时中文文件名乱码问题
func Download(c *gin.Context) { c.Writer.WriteHeader(http.StatusOK) //设置文件类型 c.Header("Content-Type", "application/vnd.ms-excel;charset=utf8") // Path ......
软件设计模式学习每日总结-第十四天
第十四天 行为型模式：对在不同对象之间划分责任与算法的抽象化。 类行为型模式：使用继承关系在几个类之间分配行为。 对象行为型模式：使用对象的聚合关联关系来分配行为。 职责链模式：避免发送者和接收者耦合，有多个发送者和接收者，这些对象形成一条职责链。 命令模式： ......
[香橙派开发系列]输入模式和上拉下拉
目录前言一、设置输入模式二、读取端口电平三、配置上拉下拉电平1.上拉输入2.下拉输入3.设置函数最后 前言 前面说了一下输出模式，这一章说一下输入模式，学完输入模式后我们就可以用一个软件模拟IIC让OLED0.96寸的显示屏显示内容了。 一、设置输入模式 前面说过设置gpio的模式的函数是pinMo ......
Java 模式匹配的演变
Java 21 之前：类型检查的故事 在 Java 21 之前的时代，模式匹配主要涉及类型检查和手动提取。这通常会导致代码冗长且容易出错，尤其是在处理复杂的数据结构时。 Java 21 的游戏规则改变者：记录模式进入 Java 21，场景发生了巨大变化。记录模式引入了一种更优雅的方式来解构这些记录对 ......
go-carbon v2.2.14 发布，轻量级、语义化、对开发者友好的 Golang 时间处理库
carbon 是一个轻量级、语义化、对开发者友好的 golang 时间处理库，支持链式调用。 目前已被 awesome-go 收录，如果您觉得不错，请给个 star 吧 github.com/golang-module/carbon gitee.com/golang-module/carbon 安装 ......
RabbitMQ 消费者可靠性——业务幂等性
如何保证业务是幂等的？ 方案一： 生产者、消费者都配置上 setCreateMessageIds(true)。配好后，生产者给MQ发消息，消息就会带上自动生成的 id。将来消费者拿到消息后，就可以获取到 id，把 id保存起来 做唯一匹配 代码示例： package com.itheima;impo ......
VMware 虚拟机的三种网络工作模式
目录介绍桥接模式桥接模式网络设置NAT模式实际操作中注意事项Host-Only 介绍 vmware为我们提供了三种网络工作模式, 它们分别是: Bridged（桥接模式）、NAT（网络地址转换模式）、Host-Only（仅主机模式）。 默认情况下，当安装完VMware虚拟机软件时，进入vmware, ......
设计模式之外观模式
1. 定义 提供了一个统一的接口，用来访问子系统中的一组接口 2. 口语化表述 工厂里组装台灯，流程、配件等有多种方式，每种台灯有自己的生产线 现在，需要某一种台灯，一种方式是直接去找这个台灯的生产线生成，这会令人烦恼，因为寻找是一件无聊而繁琐的事情 另一种方式是成立一个工厂前台，需要什么台灯就只需 ......
RabbitMQ避免重复消费
在Java中，可以使用消息队列来实现消息的异步处理，其中常用的消息队列有 RabbitMQ、ActiveMQ、Kafka 等。 什么是幂等性？ 幂等性是指无论操作执行多少次，都是得到相同的结果，而不会产生其他副作用。 在rabbitMQ中 什么是消息重复消费？ 同一条消息在MQ中被消费多次 出现重复 ......
Golang使用kcp
安装 go get -u github.com/xtaci/kcp-go import ( "fmt" "github.com/xtaci/kcp-go" "golang.org/x/net/ipv4" "golang.org/x/net/ipv6" "net" ) // KCP 服务器 func ......
深入理解HarmonyOS UIAbility：生命周期、WindowStage与启动模式探析
本文分享自华为云社区《深入理解HarmonyOS UIAbility：生命周期、WindowStage与启动模式探析》，作者：柠檬味拥抱。 UIAbility组件概述 UIAbility组件是HarmonyOS中一种包含UI界面的应用组件，主要用于与用户进行交互。每个UIAbility组件实例对应最 ......
RabbitMQ 消费者可靠性——失败重试机制
效果： 消费者抛异常后，会本地重试，如果本地重试次数达到最大重试次数之后，直接给队列返回reject，队列收到后就会丢弃该消息，也就是策略的第一种 但就这样把删了不太好，所以有了失败消息处理策略 第二种 ImmediateRequeueMessageRecoverer：消费者抛异常后，会本地重试，如 ......
RabbitMQ 消费者可靠性——消费者确认
代码示例： 在消费者的 appplication.yml 文件中加入配置： spring: rabbitmq: listener: simple: acknowledge-mode: auto ......