socket 图片.png 客户端代码 package main import ( "bufio" "fmt" "io" "net" "time" ) func main() { var tcpAddr *net.TCPAddr tcpAddr,_ = net.ResolveTCPAddr("tcp","127.0.0.1:9999") conn,err := net.DialTCP("tcp",nil,tcpAddr) if err!=nil { fmt.Println("Client connect error ! " + err.Error()) return }else { fmt.Println(conn.LocalAddr().String() + "客户端连接成功!") } d...阅读全文
一、目的 使用Go语言实现一个服务器端与客户端的聊天室。 软件：Goland，Go1.9 代码仓库地址 二、思路 1，首先启动服务器端，使用listen_socket函数监听IP地址上的客户端连接； 2，启动客户端，并向服务器端发送数据，发送结束后端口阻塞，等待服务器端的消息； 3，服务器端接收到由客户端发送来的消息； 4，服务器端向客户端发送数据，发送结束后； 5，客户端接收到由服务器端发送来的消息，发送结束后端口阻塞，等待客户端的消息； 6，重复步骤2-5； 7，如果服务器端接收到由客户端发送来的“close"消息后，服务器端关闭与客户端的连接，继续等待下一个客户端的连接； 8，客户端关闭，聊天结束。 三、Go代码实现 Sever端 // One-to-one ChatRoom Seve...阅读全文
gonet 游戏服务器架构，mmo架构，分布式snowflake64为整形uuid,ai行为树，配置data，游戏大部分都在内存运算,分布式缓存redis。设计之初，建立在actor模式下的；rpc，以及消息驱动，rpc无需注册，支持int，数据，struct（struct必须要注册结构题即可）；sql封装简单的orm，具体看demowebsocket模式下，要在net，websocket注视掉如下代码：https://studygolang.com/articles/14842代码除了mysql，protobuf，redis这几个第三方库以外，其他都是自己写的，方便性能和修改，主动权在自己手里服务器之间rpc，客户端服务器之间protobuf + rpc，客户端tcp遵从如下消息包头前四位...阅读全文
elliptic包实现了几条覆盖素数有限域的标准椭圆曲线。 type Curve type Curve interface { // Params返回椭圆曲线的参数 Params() *CurveParams // IsOnCurve判断一个点是否在椭圆曲线上 IsOnCurve(x, y *big.Int) bool // 返回点(x1,y1)和点(x2,y2)相加的结果 Add(x1, y1, x2, y2 *big.Int) (x, y *big.Int) // 返回2*(x,y)，即(x,y)+(x,y) Double(x1, y1 *big.Int) (x, y *big.Int) // k是一个大端在前格式的数字，返回k*(Bx,By) ScalarMult(x1, y1 *bi...阅读全文
类和继承 在面向对象的编程语言中存在“类”的概念，类就表示数据的类型，比如说People类；继承是指某个类是由另一个类派生出来的。生成的新类是子类，被继承的类是父类。 JS中的“var” 在某一类编程语言中会采用动态类型，是指编码时不要求指定变量类型，实际的变量类型由编译器/解释器在加载程序时动态分配。在JavaScript中用var声明变量，用let声明常量。 nil，null和undefined 通常声明变量的步骤为var a_varible = null;这里表示变量a_varible的值初始化时是空的，即null；在某些语言中是nil,比如Objective-C，Golang。有时声明变量也可以写成var a_varible,在JavaScript中，此时的变量值是undefined...阅读全文
基本概念 MSP，全称Membership Service Provider，即成员关系服务提供者，是 Hyperledger Fabric 1.0版本开始抽象出来的一个模块化组件，用来管理Fabric中的众多参与者（peer、order等）。 MSP将颁发证书和校验证书，以及用户认证背后的所有密码学机制与协议都抽象了出来。对fabric网络中的成员进行身份的管理（身份验证）与认证（签名与验签）。 image organization 和 MSP 组织ORG1拥有的MSP叫ORG1.MSP，而组织ORG2业务复杂，所以维护了3个MSP。 organization与MSP之间的专一性关系，使得在organization之后命名MSP是明智的，在大多数policy配置中，您会发现这一个惯例。 例...阅读全文
web.go package main import ( "fmt" "log" "net/http" "strings" ) func sayhello(w http.ResponseWriter, r *http.Request) { r.ParseForm() //解析参数, 默认是不会解析的 fmt.Println(r.Form) //这些是服务器端的打印信息 fmt.Println("path", r.URL.Path) fmt.Println("scheme", r.URL.Scheme) fmt.Println(r.Form["url_long"]) for k, v := range r.Form { fmt.Println("key:", k) fmt.Println("v...阅读全文
比原BMIP002协议 概述 比原链技术社区最近提出了一套资产规范提议，该提议允许在issue类型的交易中实现标准资产token。该标准定义资产在链上的基本功能，以及发行人通过智能合约管理资产的规范。 功能 资产是一种可以在区块链上发行的价值，给定资产的的所有单位都是可替代的。 每个资产都有全球唯一的资产ID,该资产ID来自发行程序和资产定义，发行程序通常定义一组可能的签名秘钥和阀值数量的签名，这些签名必需被提供以授权发布资产的新单元。 资产定义由提交给区块链的任意键值数据组成，提供所有参与者查看。 该标准为用户提供了一种发行资产的简单方法。它允许任何满足Bytom标准的token很容易被其他应用程序支持：比如钱包，区块链浏览器，到交易所。 一个例子是商家可以在很短的时间内在他们的商业应用中...阅读全文
注意： 此文章只是我的个人笔记，如有谬误，错误， 请一定指出！ package main import "fmt" //IA test for methodset. type IA interface { Value() Pointer() } //A is a test type. type A int //Value receiver. func (a A) Value() { fmt.Printf("Value:%p, %d\n", &a, a) } //Pointer receiver. func (a *A) Pointer() { fmt.Printf("Pointer:%p, %d\n", a, *a) } func main() { //type A method set: ...阅读全文
``` f, err := ioutil.ReadFile("2.npy") if err != nil { fmt.Println(err) return } tensor, err := tf.NewTensor(f) if err != nil { fmt.Println("Cannot read image file") return } tensorByte, ok := tensor.Value().([]byte) if !ok { fmt.Println("Cannot type assert tensor value to ") return } request := &pb.Predi...阅读全文
场景说明 go 中使用官方的http server方法的话，缺少统一的方法调用，无法对用户的权限等进行统一的验证 http.HandleFunc("/ws", wsHandler) 官方的这种路由方式，无法灵活的进行应用 php 中可以使用 __construct 对访问的方法进行统一的验证，而直接使用go的官方方法并没有类似的 创建简单的 http server func main() { // /ws 是url路径 http.HandleFunc("/ws", wsHandler) http.HandleFunc("/test", testHandler) http.ListenAndServe("0.0.0.0:8000", nil) } // 用户ws连接处理方法 func wsHa...阅读全文
1.格式化输出 fmt.Printf() 输出到控制台.fmt.PrintLn()输出到控制台并换行。str := fmt.Sprintf("%f", 3.1415926)格式化后返回格式化后的字符串。fmt.FprintLn(os.Stdout, "hello world")格式化输出到输出ioWrite上（控制台、文件、网络请求等）更多操作请见https://studygolang.com/stati... 2.基本IO 读取器函数 func ReadFrom(reader io.Reader, num int )([]byte, error){ p := make([]byte, num) n, err := reader.Read(p) if n>0 { return p[:n], ...阅读全文
1、MVC这个阶段主要是快速实现产品，没考虑其他的，设计之初划分多个app，app内高类聚，app之间低耦合，DB表设计好了之后，实现view层功能需求，利用Django来快速实现功能，后端有许多预留设计，避免产品逻辑的变更带来整个表结构的变动，架构如下图； MVC架构nginx是负载均衡，通过权重法，把请求发送到多个Django服务（其实中间还有一个uwsgi)，如果是静态请求，nginx直接返回给客户端，如果是其他请求，通过uwsgi传给Django，Django拿到请求，处理响应请求。耗时大的需要异步的，我们用celery处理，使用mysql作为数据库，redis作为缓存，加快请求的响应，减轻mysql负担，同时还有实时消息通知的需要使用了Nginx Push Module。问题以及处...阅读全文
点击上方蓝色“Go语言中文网”关注我们，领全套Go资料，每天学习 Go 语言Todd Kulesza 2020-04-20概览、感谢 首先，我要非常感谢参与本次调查的数千名 Go 开发人员。在 2019 年，我们收到了 10,975 份回复，几乎是去年的两倍！[1]我要代表团队的其他成员，充分强调您花时间和精力向我们介绍您在 Go 方面的经验，我们对此深表感谢。谢谢！关于前几年调查说明 敏锐的读者可能会注意到，我们每年的比较与我们过去分享的数字不太吻合。原因是从 2016 年至 2018 年，我们使用开始调查的总人数作为分母来计算每个问题的百分比。尽管这很不错而且很一致，但它忽略了并非每个人都会完成调查的事实——多达 40％ 的参与者在到达最后一页之前就停止了调查，这意味着在调查的后面出现的...阅读全文
golang的plugin功能用的比较少，官方的示例只有返回函数，而没有返回对象。但是实际应用中OOP可以极大提高程序的质量，经过我自己试验，发现plugin是可以返回对象的。 返回类型 我试验的返回对象的类型是空接口，然后用类型断言转换成含有一组约定方法的接口。 实例 我们首先在主程序中定义一个约定返回接口： type ResObj interface { Say(string) int } 插件中的对象定义和返回接口的函数： //对象定义 type ObjType struct { //内部封装数据 Name string } //Say 方法的实现 func (p *ObjType) Say(s string) int { fmt.Printf("%s say: %s\n", p.Na...阅读全文
HTTP 协议于 1991 年引入，至今已有近 30 年的历史。自第一个文档化版本 (后来称为 0.9) 以来，它已经经历了一段相当长的历程。在本文中，我们将简要回顾 HTTP 协议的发展历史，重点介绍 HTTP/2 带来了什么，以及我们如何从中获益。我们将使用 Node.js 服务端来实现它。1HTTP 协议简史HTTP 的第一个版本只能传输超文本标记语言 (HTML) 文件，因此我们称之为超文本传输协议。它真的很简单，唯一可用的方法就是 GET。它没有 HTTP 头文件或状态代码。如果出现问题，服务器可以使用带有错误描述的 HTML 文件进行响应。1996 年 1.0 版本出现了。与前一个版本相比，它进行了许多改进，其中最重要的是状态代码、POST 和 header 等附加方法。现在，我...阅读全文
(以 Ubuntu 桌面版开发环境为例)步骤1: 安装Go语言编译器 sudo apt install golang-go 上述命令在Ubuntu 17.04下默认将安装1.7版本的Go编译器. 安装完毕后可以运行 go version查看编译器版本号. 步骤2: Hello world 程序测试创建任意目录以便分类存放测试程序, 然后在自己新建的目录下创建一个测试程序, 这里我们新建一个文件并保存为 hello.go, 内容如下: package main import "fmt" func main(){ fmt.Println("hello world\n") } 进入Linux终端窗口, cd命令切换到 hello.go 所在的目录下, 输入go build命令编译源代码, 得到一个...阅读全文
本文系第十一篇Golang语言学习教程 数组 数组是同一类型元素的集合。一个数组可以由0个或多个元素组成。 定义数组的格式： var
载： https://mp.weixin.qq.com/s/JgNgmYasXaTqrx5OeeD5KQ 2016 年下半年开始，FreeWheel 开始将其业务系统从 Rails 单体应用逐步迁移到微服务，同时技术栈从 Rails 改为 Golang，两年之后，整个迁移接近尾声，FreeWheel 业务系统技术团队对外分享了它们在微服务化过程中的经验。 原有架构的问题 FreeWheel 是一家为客户提供数字视频广告管理技术和服务的公司。其业务端产品需要对接客户，提供视频广告投放优化界面，类似于 Web ERP，该业务系统采用 Rails 技术栈开发，其架构是一个典型的三层架构。 image 这个系统经过近十年的研发和迭代，代码量达到数十万行，业务的特殊性和代码的复杂度让团队的维护和新功能...阅读全文
ssmperf 是 SSMP 协议的服务器基础加载测试工具。 使用
./ssmperf <address> [flags] -cacert="" path to CA cert -cert="" path to client cert -conn=100 number of client connections -count=10000 number of messages sent per connection -cpuprofile="" write cpu profile to file -insecure=false d...阅读全文
来自公众号：后端技术学堂 作者LemonCoder 单体式应用程序 与微服务相对的另一个概念是传统的「单体式应用程序」( Monolithic application )，单体式应用内部包含了所有需要的服务。而且各个服务功能模块有很强的耦合性，也就是相互依赖彼此，很难拆分和扩容。 在座的各位都写过单体程序，给大家举个栗子，刚开始写代码你写helloworld 程序就是单体程序，一个程序包含所有功能，虽然helloworld 功能很简单。 单体应用程序的优点 开发简洁，功能都在单个程序内部，便于软件设计和开发规划。 容易部署，程序单一不存在分布式集群的复杂部署环境，降低了部署难度。 容易测试，没有各种复杂的服务调用关系，都是内部调用方便测试。 单体应用程序的缺点 单体程序的缺点一开始不是特别明...阅读全文
Wire使用教程 Wire是Google提供的帮助Go开发人员实现编译时依赖注入的工具。通过例子学习使用Wire。这里我们要建立一个小的欢迎程序，用来了解如何使用Wire。 构建欢迎程序的第一步 让我们创建一个小程序，它模拟一个事件，其中包含一个带有特定消息的欢迎来宾的问候语。 我们创建了三种数据类型 给迎宾员的信息 传达信息的迎宾员 以迎宾开始的活动 type Message string type Greeter struct { // ... TBD } type Event struct { // ... TBD } 现在，我们将创建一个简单的初始化器，总是返回一个硬编码的消息: func NewMessage() Message { return Message("Hi there...阅读全文
1. 对象存活判断 1.1. 引用计数算法 Reference Counting 给对象添加一个引用计数器，每当有一个地方引用它的时候，计数器值就加一；当引用失效时，计数器值就减一；任何时刻计数器为0的对象就是不可能再被使用的。 主流的JVM没有选用引用计数算法来管理内存，主要的原因是它很难解决对象之间的相互循环引用的问题。 1.2. 可达性分析算法 Reachability Analysis 通过一系列称为“GC-Roots”的对象作为起点，从这些结点开始向下搜索，搜索所走过的路径称为引用链（Reference Chain），当一个对象到GC Roots没有任何引用链相连时，则证明此对象是不可用的（图论中的不可达）。 可作为GC Roots的对象： 虚拟机栈（战争中的本地变量表）中引用的对...阅读全文
Golang 支持在一个平台下生成另一个平台可执行程序的交叉编译功能。 1、Mac下编译Linux, Windows平台的64位可执行程序 $ CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build test.go $ CGO_ENABLED=0 GOOS=windows GOARCH=amd64 go build test.go 2、Linux下编译Mac, Windows平台的64位可执行程序 $ CGO_ENABLED=0 GOOS=darwin GOARCH=amd64 go build test.go $ CGO_ENABLED=0 GOOS=windows GOARCH=amd64 go build test.go 3、Windows下编译M...阅读全文
作者：Max 一直以来都有个梦想： 希望有一个数据库能够弹性扩展（分布式）到成百上千节点的规模，易于学习和理解，可以运行在私有云、公有云、Multi-Cloud、Kubernetes，也能够跑在嵌入式设备（比如树莓派）上，更酷的是也能够直接运行在浏览器里，而且不需要任何浏览器扩展（Extension），变成「口袋数据库」，就像那部电影《蚁人》。 今天，这一切都变成了现实：TiDB 可以直接运行在浏览器本地。打开浏览器，你可以直接创建数据库，对数据进行增删改查。关掉浏览器，一切都消失了，干净绿色环保—— 首先在笔记本浏览器打开 play.pingcap.com（这里用的是 MacOS 上面的 Chrome，不确定其它浏览器是否正常），可能需要几秒来加载页面，然后就能看到熟悉的 Shell 了。...阅读全文
简介 Github 地址 博客原文 本文使用 go 实现了一个多人聊天室，参考文章为 Writing a Chat Server in Go，点击查看中文翻译版。 本文的特点在于：将原始项目分为自底向上的若干个阶段，新手可以一步步地实现系统的不同模块，逐渐掌握相应知识点。源码里有详细的注释，引导你在不看源代码的情况下自己实现相应代码。 本文假设你： 了解 go 语言的基本语法 了解 git 的使用 完成本项目，你将学会这些内容： Reader 方法的基本使用 使用 net 包实现一个 tcp 服务器：监听端口、建立连接、提供服务 sync 加锁 goroutine 与 channel gob 的基本使用 运行 运行环境：go 1.13.1 打开 GO111MODULE，运行 go mod d...阅读全文
课程介绍 阿里云虚拟主机市场占用率第一，20年专业品质保证；产品特点：预装网站运行环境，赠送正版数据库，可通过图形化控制面板管理，主要用于搭建网站。 独享系列虚机特点：客户独享整台服务器资源，无资源争抢更稳定，不限流量更快速、独立IP更易推广，适合企业建站客户； 共享系列虚机特点：多客户共享服务器硬件资源，价格优惠，简单易用，适合于开发者、个人站长建站； 产品详情：https://wanwang.aliyun.com/hosting/ 课时列表 • 课时1：购买虚拟主机和初始化密码信息 • 课时2：FTP 上传与解压缩文件 • 课时3：绑定并解析域名 • 课时4：切换语言环境 • 课时5：虚拟主机临时域名的使用 开始学习http:...阅读全文
文地址：Golang 大杀器之性能剖析 PProf 前言 写了几吨代码，实现了几百个接口。功能测试也通过了，终于成功的部署上线了 结果，性能不佳，什么鬼？???? 想做性能分析 PProf 想要进行性能优化，首先瞩目在 Go 自身提供的工具链来作为分析依据，本文将带你学习、使用 Go 后花园，涉及如下： runtime/pprof：采集程序（非 Server）的运行数据进行分析 net/http/pprof：采集 HTTP Server 的运行时数据进行分析 是什么 pprof 是用于可视化和分析性能分析数据的工具 pprof 以 profile.proto 读取分析样本的集合，并生成报告以可视化并帮助分析数据（支持文本和图形报告） profile.proto 是一个 Protocol Bu...阅读全文
Home Menu 解析器眼中的 Go 语言 02 Feb 2019 Golang Go实现原理 编译原理 词法分析 语法分析 抽象语法树 词法分析 lex Go 语法分析 文法 分析方法 自顶向下 自底向上 Lookahead Go 辅助方法 节点 总结 相关文章 Reference 代码其实就是按照约定格式编写的一堆字符串，工程师可以在脑内对语言的源代码进行编译并运行目标程序，这是因为经过训练的软件工程师能够对本来无意义的字符串进行分组和分析，按照约定的语法来理解源代码。既然工程师能够按照一定的方式理解和编译 Go 语言的源代码，那么我们如何模拟人理解源代码的方式构建一个能够分析编程语言代码的程序呢。 我们在这一节中将介绍词法分析和语法分析这两个非常重要的编译过程，这两个过程的主要作用就...阅读全文
k8s与HPA--通过 Prometheus adaptor 来自定义监控指标 自动扩展是一种根据资源使用情况自动扩展或缩小工作负载的方法。 Kubernetes中的自动缩放有两个维度：Cluster Autoscaler处理节点扩展操作，Horizontal Pod Autoscaler自动扩展部署或副本集中的pod数量。 Cluster Autoscaling与Horizontal Pod Autoscaler一起用于动态调整计算能力以及系统满足SLA所需的并行度。虽然Cluster Autoscaler高度依赖托管您的集群的云提供商的基础功能，但HPA可以独立于您的IaaS / PaaS提供商运营。 Horizontal Pod Autoscaler功能最初是在Kubern...阅读全文
前几天[Thiago Pontes](https://twitter.com/thiagopnts) 分享了一篇关于异常被认为是反模式的博客给他的几个朋友。我对异常有一个不同的观点。我想如果写一个关于 exceptions 的博客会非常的有趣。我认为异常是一个非常好的功能，如果缺少异常可能会引起更大的错误。 这篇博客引用了我朋友分享的帖子：[Python exceptions considered an anti-pattern.](https://sobolevn.me/2019/02/python-exceptions-considered-an-antipattern) ## 没有异常的程序 如果你曾经用过 C 语言，你就记得 -1 和 NULL 作为返回值意味着错误，或者在这些情况下...阅读全文
用 Go 来了解一下 Redis 通讯协议 Go、PHP、Java... 都有那么多包来支撑你使用 Redis，那你是否有想过 有了服务端，有了客户端，他们俩是怎样通讯，又是基于什么通讯协议做出交互的呢？ 介绍 基于我们的目的，本文主要讲解和实践 Redis 的通讯协议 Redis 的客户端和服务端是通过 TCP 连接来进行数据交互， 服务器默认的端口号为 6379 客户端和服务器发送的命令或数据一律以 \r\n （CRLF）结尾（这是一条约定） 协议 在 Redis 中分为请求和回复，而请求协议又分为新版和旧版，新版统一请求协议在 Redis 1.2 版本中引入，最终在 Redis 2.0 版本成为 Redis 服务器通信的标准方式 本文是基于新版协议来实现功能，不建议使用旧版（1.2 挺...阅读全文
Why 大约两年前，Tinder决定将其平台移至Kubernetes。 Kubernetes为我们提供了一个通过不变的部署推动Tinder Engineering朝着容器化和少运维的方向发展的机遇。应用程序的构建，部署和基础结构将定义为代码。 我们还希望解决规模和稳定性方面的挑战。当扩展变得至关重要时，我们常常要等待几分钟才能等待新的EC2实例上线。容器在数秒而不是数分钟内调度和服务流量的想法吸引了我们。 这并不容易。在2019年初的迁移过程中，我们在Kubernetes集群中达到了临界规模，并且由于流量，集群规模和DNS而开始遇到各种挑战。我们解决了迁移200个服务并运行Kubernetes集群的有趣挑战，该集群的规模总计为1,000个节点，15,000个Pod和48,000个正在运行的容...阅读全文
我们在开发时，有时会碰到一个接口的访问量突然上升，导致服务响应延迟或者宕机的情况。这时，除了利用缓存之外，也可以用到singlefilght来解决，下面是一个简单的示例 package main import ( "fmt" "sync" "sync/atomic" "time" "golang.org/x/sync/singleflight" ) func main() { g := singleflight.Group{} wg := sync.WaitGroup{} for i := 0; i < 100; i++ { wg.Add(1) go func(j int) { defer wg.Done() val, err, shared := g.Do("a", a) if err !...阅读全文
一、背景 最近接手一个 golang 的项目，存储于 gitlab 上，由于之前主要是 PHP 开发，版本库用得比较多的也是 SVN，此次的项目想要使用 Gitlab 自带的 CI 持续集成工具进行自动编译打包部署，之前从未接触过此类东西，故在网上苦苦寻觅，浏览了无数资料，踩了无数的坑，现将主要过程以及一些坑整理分享出来，方便即将入坑的朋友。 参考文献： GitLab-CI 从安装到差点放弃 使用gitlab的Ci自动部署项目 pipeline gitlab-runner 二、相关解释 1. Gitlab GitLab 是一个利用 Ruby on Rails 开发的开源应用程序，实现一个自托管的 Git 项目仓库，可通过 Web 界面进行访问公开的或者私人项目。 它拥有与 GitHub 类似...阅读全文
tees/channels.go package tees type TeeOp struct { } func NewTeeOp() *TeeOp { teeOp := &TeeOp{} return teeOp } func (teeOp *TeeOp) OrDone( done, c <-chan interface{}, ) <-chan interface{} { valStream := make(chan interface{}) go func() { defer close(valStream) for { select { case <-done: return case v, ok := <-c: if ok == false { return } select { c...阅读全文
互联网后台的最大特点就是海量请求，如何在有限的资源下尽可能服务更多的请求是后台开发主要的关注点。传统上设计一个高可用高并发的互联网后台主要原则有横向扩展和纵向扩展。横向扩展要求服务尽量无状态依赖，纵向扩展主要是提高单机的吞吐量，比如使用更好的硬件配置。在编程模型的选择上，采样哪种并发模型也会大大影响单机的吞吐量(参考著名的 C10K 问题)。 上古时期的互联网服务 以早期的 web 服务为例，浏览器中地址栏输入网址回车后，发起 HTTP 请求到 web 后台。web 容器(apache)收到请求后，解析请求然后生成浏览器需要的数据(读取静态文件或者启动一个 cgi 进程生成动态内容)，最后通过 HTTP 响应返回给浏览器。 屏蔽掉网络通信息协议，进程间通信等等各种细节，以上例子可以说明一个互...阅读全文
Golang 支持交叉编译，在一个平台上生成另一个平台的可执行程序，最近使用了一下，非常好用，这里备忘一下。 Mac 下编译 Linux 和 Windows 64位可执行程序 CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build main.go CGO_ENABLED=0 GOOS=windows GOARCH=amd64 go build main.go Linux 下编译 Mac 和 Windows 64位可执行程序 CGO_ENABLED=0 GOOS=darwin GOARCH=amd64 go build main.go> CGO_ENABLED=0 GOOS=windows GOARCH=amd64 go build main.go Win...阅读全文
请教一个问题：我多个硬件设备通过udp跟服务器连接，他会隔1小时给服务器去上报数据 每个设备是有唯一的标识码IMEI 现在想通过服务器把数据发给指定设备 该怎么操作 之前的做法是 当设备连接服务器时就把UDPAddr的对象存到一个map里 key值为imei号 但是设备连着 第二次发报文后 ip是不会变的 端口变了 我想用WriteToUDP 就找不到接受对象...阅读全文
2.蛤蟆笔记go语言——包 每个 Go 程序都是由包组成的。 程序运行的入口是包 main。 这个程序使用并导入了包 "fmt" 和"math/rand"。 按照惯例，包名与导入路径的最后一个目录一致。例如，"math/rand" 包由 package rand 语句开始 代码 package main import ( "fmt" "math/rand" ) func main() { fmt.Println("Myfavorite number is", rand.Intn(10)) } 执行如下： Myfavorite number is 1 导入 代码用圆括号组合了导入，这是“打包”导入语句。 同样可以编写多个导入语句，例如： import "fmt" import "math" 不...阅读全文
本文系第八篇Golang语言学习教程 switch是一个条件语句，用于将表达式的值与可能匹配的选项列表进行比较，并根据情况执行相应代码。是替代if else的常用方式。 下面通过讲解一个简单的运算程序来了解switch语句 package main import "fmt" func eval(a, b int, op string) int { //定义eval函数，输入三个值 a, b, op 输出类型为 int var result int switch op { // op 为表达式，将 op 的值与下面 case 比较 case "+": //若 op 值为 + , 则将 result 赋值 a + b 以此类推 result = a + b case "-": result = ...阅读全文
访问网络服务 这篇开始讲网络编程。不过网络编程的内容过于庞大，这里主要讲socket。而socket可以讲的东西也太多了，因此，这里只围绕Go语言介绍一些它的基础知识。 IPC方法 所谓socket，是一种IPC（Inter-Process Communication）方法，可以被翻译为进程间通信。顾名思义，IPC这个概念（或者说规范）主要定义的是多个进程之间，相互通信的方法。这些方法主要包括： 系统信号（signal），os包和os/signal包有针对系统信号的API 管道（pipe），os.Pipe函数可以创建命名管道，os/exec包支持另一类管道：匿名管道 套接字（socket），net包中提供支持 文件锁（file lock） 消息队列（message queue） 信号灯（se...阅读全文
go语言高级编程笔记 并发编程 一、并发编程的相关概念 １、并发编程概念：使多个任务【程序】可以在同一时间执行以便能够更快的得到结果 ２、多元程序：允许操作系统同时运行多个程序，cpu来回切换，缺点：对系统资源进行无限制的抢夺造成程序频繁发生死锁现象 ３、串行程序：只能被顺序执行的指令列表 ４、并行程序：可以在并行的硬件上执行的并发程序 ５、并发程序：被并发的执行的两个或两个以上的串行程序的统称 ６、并发系统 ７、并发程序的不确定性：没有明确的执行顺序 ８、并发程序的内部交互 同步的原则：某个资源同一时刻只能被一个程序占用 同步的作用：避免在并发访问共享资源时可能存在的冲突，以及确保在互相传递数据时能够顺利的接通 二、多进程编程 1、IPC：多进程程序中，程序之间需要互相协作完成任务，而多个...阅读全文
package main import ( "fmt" "sync" "time" ) /* WaitGroup用于等待一组线程的结束。父线程调用Add方法来设定应等待的线程的数量。每个被等待的线程在结束时应调用Done方法。 同时，主线程里可以调用Wait方法阻塞至所有线程结束。 */ var wg sync.WaitGroup func test(i int){ fmt.Println("test func...", i) time.Sleep(time.Second) // 表示goroutine已经执行完成 wg.Done() } func main() { var count = 100 // 添加goroutine计数器 wg.Add(count) for i:=0;i
开发十年，就只剩下这套Java开发体系了 >>> time package in there //time package //time 包为我们提供了一个数据类型 time.Time（作为值使用）以及显示和测量时间和日期的功能函数 //当前时间可以使用 time.Now() 获取，或者使用 t.Day()、t.Minute() 等等来获取时间的一部分；你甚至可以自定义时间/// 格式化字符串，例如： fmt.Printf("%02d.%02d.%4d\n", t.Day(), t.Month(), t.Year()) 将会输出 21.07.2011 //Duration 类型表示两个连续时刻所相差的纳秒数，类型为 int64。Location 类型映射某个时区的时间，UTC 表示通用协调/...阅读全文
版权声明：本文为博主Liigo原创，未经授权不得转载。 https://blog.csdn.net/liigo/article/details/7467309 Go语言（golang）第一个正式版Go1发布了，但是这个新兴的编程语言还是非常不完善。这不，我（Liigo）又发现它的编译器竟然不支持编译带BOM的UTF-8编码的.go源文件。这就很奇怪，该语言明明要求源代码文件.go必须是UTF-8编码，但又不允许带UTF-8 BOM。要知道，这个世界上带BOM的文件太多了，很多文本编辑器/代码编辑器/IDE支持生成、甚至默认生成带有BOM的UTF-8文件。如果仅仅因为源代码文件多了BOM，编译器就不能编译这个文件，那也太低能了。 Go语言编译器(gc)不支持带有BOM的UTF-8源文件： Go...阅读全文
模板方法模式 定义一个操作中的算法的骨架，而将一些步骤延迟到子类中。 模板方法使得子类可以不改变一个算法的结构即可重定义该算法的某些特定步骤 Lock接口及其实现 中，DemoReentrantLock 和 DemoReadWriteLock 代码相似度很高。DemoReentrantLock 中的加解锁完全可以用DemoReadWriteLock中代替，即可实现加解锁。 优化两个锁的代码-采用模板方法模式 CommonMask实现两个锁共有的方法 import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurr...阅读全文
微服务架构将某个单一的复杂系统拆分成多个可独立自治的服务，服务之间通过松耦合的方式进行交互，这为我们带来了许多好处，包括低耦合、可重用性、业务敏捷性和分布式部署能力、强扩展性。但于此同时，也给我们引进了新的挑战。 在微服务场景下，每个模块之间的互通都通过远程调用的方式来代替传统单体架构中的内存调用，在获得扩展性、重用性的同时，也使得整个体系结构因为网络的不稳定性、资源的过量使用变得更加脆弱。当一项或多项依赖服务持续不可用或出现高延迟时，将会导致整个服务级联失败。而且，服务客户端中的重试逻辑会使呈现高延迟的服务状况恶化，最终使整个系统陷入瘫痪。就像多米诺骨牌效应一样推倒整个系统。 duominuo.jpg 为了提高服务的可用性，避免级联影响，最经典的解决办法之一就是在服务之间的RPC边界引入...阅读全文
课程介绍 本课程主要讲解企业级分布式应用服务EDAS相关技术和使用方法。 企业级分布式应用服务（EDAS，Enterprise Distributed Application Service）是企业级互联网架构解决方案的核心产品，充分利用阿里云现有资源管理和服务体系，引入中间件成熟的整套分布式计算框架（包括分布式服务化框架、服务治理、运维管控、链路追踪和稳定性组件等），以应用为中心，帮助企业级客户轻松构建并托管分布式应用服务体系。 课程目标 掌握企业级分布式应用服务EDAS的使用 适合人群 云计算开发者 课时列表 • 第1 章 ： EDAS介绍 • 课时1：EDAS介绍 • 第2 章 ： EDAS...阅读全文
好程序员分享：Hadoop集群同步分享——是技术突飞猛进的很好体验!在好程序员学习大数据技术，开始学会了分享，班里五十个人，每个人就能得到49份不同技术探讨。每次到分享的时刻，总会收获不同的想法。一、同步方式 选择一个机器，作为时间服务器(这里选择hadoop01)，所有的机器与这台集群时间进行定时的同步，比如，每隔十分钟，同步一次时间。二、所需工具 时间同步服务器有两个：ntpd和ntpdatp。虽然使用二者都能达到时间同步的目的，但是使用之前得弄清楚一个问题，ntpd与ntpdate在更新时间时有什么区别。ntpd不仅仅是时间同步服务器，它还可通过客户端与标准时间服务器进行时间同步，而且是平滑同步，并非ntpdate立即同步，在生产环境中慎用ntpdate，也正如此两者不可同时运行。三、...阅读全文
