分类目录归档：golang

2022
01-14

golang内存对齐 NEW

unsafe.Sizeof(x)在Go语言中，我们可以通过 unsafe.Sizeof(x) 来确定一个变量占用的内存字节数（不包含 x 所指向的内容的大小）例如对于字符串数组，在64位机器上，unsafe.Sizeof() 返回的任意字符串数组大小为 24 字节，和其底层数据无关：func main() {  s := []string{"1", "2", &qu... Read More >

2022
01-13

redis延迟队列golang高效实践 NEW

一、背景业务中经常会有这样的场景：到期后自动执行指定操作；查询某个任务是否完成，未完成等待一定时间再次查询；回调通知，当回调失败时，等待后重试；等等还有其他很多类似的场景。很多时候我们会直接通过一个本地定时器来帮我们完成这个任务。如果我们的系统是多实例分布式的，本地定时器就会面临很多问题，如：怎么保证重复处理的问题；统一管控的问题等等。面对本地定时器遇到的问题，我们可以使用分布式延迟队列来实现。这里介绍一种使用golang基于redis实现延迟队列的具体实践。二、实现原理1、... Read More >

2022
01-12

golang-websockets客户端实现和压测方法 NEW

简介使用到的包：github.com/gorilla/websocket案例package main   import (     "fmt"     "github.com/gorilla/websocket"     "log"   ... Read More >

2022
01-11

golang中redis对redigo的发布订阅机制的使用

redigo 对redis的订阅机制放在pubsub.go里面,PubSubConn封装Conn以实现订阅者提供简便方法。Subscribe，PSubscribe，Unsubscribe和PUnsubscribe方法发送和刷新订阅。receive方法将推送的消息转换对应的类型// Receive returns a pushed message as a Subscription, Me... Read More >

2022
01-10

gorilla/websocket包方法汇总

获取 Conn 实例的方法func (u *Upgrader) Upgrade(w http.ResponseWriter,r *http.Request,responseHeader http.Header)(*Conn , error)    方法 必须通过 Upgrader结构体的实例调用    方法必须传递 w http.ResponseWriter 和  r *http.Req... Read More >

2022
01-09

高效的IM长连接自适应心跳保活机制

认识长连接长连接的主要作是通过长时间保持双方连接，从而：提高通信速度；确保实时性；避免短时间内重复连接所造成的信道资源和网络资源的浪费。长连接与短连接的区别导致长连接断开的原因1. 长连接所在进程被杀死（这主要说的是移动端）；2. NAT超时；3. 网络状态发生变化；4. 其他不可抗因素（网络状态差、DHCP的租期等等 ）。下面，我将对每种原因进行分析。具体分析1）原因1：进程被杀死当进程被杀死后，长连接也会随之断开。进程被杀在Andriod端是最常见的问题，限于篇幅就不在此... Read More >

2022
01-08

长连接为什么需要心跳检测

背景首先，无论是自己设计的长连接还是websocket长连，都需要自己设计心跳机制来维持长连。从应用层协议来看，维持一个建立连接的必要条件似乎就是客户端和服务端均维持双方的连接信息，均用一个结构体来描述连接五元组（协议+源ip+源端口+目的ip+目的端口）。那么，是不是只要双方在应用层保证双方的连接信息不被清掉，就可以一直维护长连接呢。答案自然是否定的，长连接都是建立在TCP协议上的，所以我们先要了解操作系统是如何维护TCP协议连接状态的。TCP 连接状态所谓的TCP连接不是... Read More >

2022
01-07

开源OpenIM：高性能、可伸缩、易扩展的即时通讯架构

产品体验地址web端体验地址：http://121.37.25.71:23232/pc端下载： https://pan.baidu.com/s/16MW36rKVFtDCBewMOdD0pA 密码: jd15安卓下载：https://www.pgyer.com/OpenIM官方文档：https://doc.rentsoft.cn/github地址：https://github.com/OpenIMSDK/Open-IM-Server网上有很多关于IM的教程... Read More >

2022
01-06

关于股票除权复权，前复权、后复权、不复权

除权：简单讲就是 让市场上可以流通的股票变多了，每股的权益变少叫除权。假设某公司的总股本100股，每股10元，总权益就是1000元。当公司进行送股，每10股转送10股，总股本就变成了200股，而公司的总权益并没有变，于是每股价格就要变成1000/200=5元。这就是除权。复权：两股合成一股，叫复权，回复股票权利。当股价因送股、配股等原因而发生下跌时，原来10元/股的股票瞬间变成了5元/股，但该股票实际价值并没有发生变化，也就是说现在的5元实际上还是相当于10元。这就是复权。&... Read More >

2022
01-05

随机指标(KDJ)的计算方法和golang实现

KDJ指标的定义KDJ的另外一个名字叫随机指标，最早是以KD指标的形式出现，而KD指标是在威廉指标的基础上发展起来的，目前是金融市场上最常用的技术分析工具之一。KDJ 指标的原理利用当前股价(包括大盘指数，下同)在近期分布中的相对位置来预测可能发生的趋向拐点。它是利用市场价格真实的波动来反映价格走势的强弱以及超买超卖现象，从而在价格尚未出现明显的上升或下降之前提前发出交易信号，它是捕捉市场价格即将要发生拐点的一种技术工具。KDJ指标的计算方法KDJ指标是一种常用的价格走势判断... Read More >

2022
01-05

股票中MACD如何计算golang版本

概念    MACD称为指数平滑移动平均线，是从双指数移动平均线发展而来的，由快的指数移动平均线（EMA12）减去慢的指数移动平均线（EMA26）得到快线DIF，再用2×（快线DIF-DIF的9日加权移动均线DEA）得到MACD柱。MACD的意义和双移动平均线基本相同，即由快、慢均线的离散、聚合表征当前的多空状态和股价可能的发展变化趋势，但阅读起来更方便。当MACD从负数转向正数，是买的信号。当MACD从正数转向负数，是卖的信号。当MA... Read More >

2022
01-04

go自定义包引入，报错包找不到的问题

背景从github下载了一个项目想运行下，发现找不到自己写的包，一直报错build command-line-arguments: cannot find module for path xxx目录结构stockIndicator    indicator        price.go   &nb... Read More >

2022
01-03

livego介绍、安装、使用详解

前言写这篇文章主要是因为希望找到一个简单的方式实现直播功能，在度娘上找到livego（我平时写php和前端的，不懂golang），感觉安装部署都很方便，即使不懂golang的同学，只要有一定Linux和web后端开发知识都能搭建自己的直播服务。但是livego的文档的确比较少，然后对于我这个面向搜索引擎开发的菜鸟来说，连度娘也只找到为数不多的几篇相关博客文章，所以最后只能自己看GitHub的issue和反复测试趟坑，最后打算记录一下自己的趟坑过程也分享一下给各位小伙伴，希望对... Read More >

2022
01-02

什么是OBS（OBS直播推流操作步骤，看完就懂）

什么是 OBS？ Open Broadcaster Software 是一款好用的互联网流媒体直播内容输入作软件。 OBS 使用是否收费？ 不收费，这个程序和它的源代码都是免费的。 OBS 都支持哪些操作系统？ 支持 OS X、Windows、Linux 操作系统。适用于多种直播场景。满足大部分直播行为的操作需求。 一、前期准备 直播间布置 参考：直播间布置手册：https://www.yuque.com/docs/share/555b3... Read More >

2022
01-01

一篇文章搞清楚直播协议RTMP

    说起RTMP协议，相信很多人都比较陌生，这个协议相对HTTP、HTTPS、TCP等我们常见的协议而言，我们在工作中确实较少接触它，但是对现在如火如荼的直播行业，RTMP是一个重要的协议，它在实时音视频场景中使用非常广泛，而且目前市占率很高。本文的主要内容是分析RTMP的协议，当然不是纯理论分析，这样没多大意思，还是结合实践抓包文件来具体分析，这样才能较好地理解RTMP的内涵。具体如何抓包见本文末尾的“Android抓包”模块。希... Read More >

2021
01-29

gorm中查询范围scope详解

介绍Scopes 使你可以复用通用的逻辑，共享的逻辑需要定义为 func(*gorm.DB) *gorm.DB 类型实战func AmountGreaterThan1000(db *gorm.DB) *gorm.DB {   return db.Where("amount > ?", 1000) } func P... Read More >

2021
01-28

gin获取http中的body参数

post发送数据有几种形式，form和流是最常用的。特别是在程序里使用httpclients，一般都算通过流发送。在php里，是通过php://input来获取的。在gin中，可以通过c.Request.Body.Read(buf)。具体代码如下：package main   import (     "fmt"     "net... Read More >

2021
01-27

gorm没有deleted_at的查询如何去掉这个条件判断之unscoped

背景当tableStruct内部有gorm.Model时，默认的查询语句都会包含 deleted_at IS NULL 的判断，如何不限制这个条件呢？原理分析gorm.Model 是一个包含一些基本字段的结构体, 包含的字段有 ID，CreatedAt， UpdatedAt， DeletedAt解决方法1. Unscoped方法model.Db.Debug().Unscoped().Where(map[string]interface{}{"id":&nb... Read More >

2021
01-26

go中redigo操作以及连接池（github.com/garyburd/redigo/redis）

conn：package main import (     "fmt"     "github.com/garyburd/redigo/redis" ) func main() {     c, err := redis.D... Read More >

2021
01-26

golang与redis连接池的那些注意事项

一、什么是连接池，连接池有什么用先看看别人是怎么介绍连接池的吧:连接池基本的思想是在系统初始化的时候，将数据库连接作为对象存储在内存中，当用户需要访问数据库时，并非建立一个新的连接，而是从连接池中取出一个已建立的空闲连接对象。使用完毕后，用户也并非将连接关闭，而是将连接放回连接池中，以供下一个请求访问使用。而连接的建立、断开都由连接池自身来管理。同时，还可以通过设置连接池的参数来控制连接池中的初始连接数、连接的上下限数以及每个连接的最大使用次数、最大空闲时间等等。也可以通过其... Read More >