在go语言里面定义字符串如下： var ss string = "12345" 对于一个熟悉C/C++的程序员来说，马上就会想到这个string是一个什么内容，占多大空间，内存如何分配等，下面我们来分析这个问题。 go语言的string是一种数据类型，这个数据类型占用16字节空间，前8字节是一个指针，指向字符串值的地址，后八个字节是一个整数，标识字符串的长度；注意go语言的字符串内部并不以'\0'作为结尾，而是通过一个长度域来表示字符串的长度。 type mystr struct { strbuf uintptr; strlen uint64; } 上述就是string的类型定义。下面我们通过代码来验证这个问题： package main import ( "fmt" "unsafe" //...阅读全文
了解一下Golang的市场行情 项目地址：https://github.com/go-crawler... 如果对你有所帮助，欢迎 Star，给文章来波赞 :) 目标 在工作中 Golang 已是一份子，想让大家了解一下 Golang 的市场行情，也想让更多的人熟悉它。因此主要是展示数据分析的结果 目标站点是 某招聘网站 的职位数据抓取和分析，爬取城市分别为 北京、上海、广州、深圳、杭州、成都，再得出一个结论 分析 首先需要进行页面分析，找到我们的抓取方向 搜索 golang 关键字，打开页面 F12 就能看到它发送了四个请求，留意 positionAjax.json 这个请求 我们仔细研判这个接口的入参和出参 入参 1、Query String Param city：请求的城市 needA...阅读全文
Transaction 事务 事务处理是数据的重要特性。尤其是对于一些支付系统，事务保证性对业务逻辑会有重要影响。golang的mysql驱动也封装好了事务相关的操作。我们已经学习了db的Query和Exec方法处理查询和修改数据库。 tx对象 一般查询使用的是db对象的方法，事务则是使用另外一个对象。sql.Tx对象。使用db的Begin方法可以创建tx对象。tx对象也有数据库交互的Query,Exec和Prepare方法。用法和db的相关用法类似。查询或修改的操作完毕之后，需要调用tx对象的Commit提交或者Rollback方法回滚。 一旦创建了tx对象，事务处理都依赖与tx对象，这个对象会从连接池中取出一个空闲的连接，接下来的sql执行都基于这个连接，直到commit或者rollba...阅读全文
每个连接开一个goroutine 上万个连接就有上万个for 不能accept到数据了再开goroutine吗 还不用做redis 数据库连接池维护 ...阅读全文
/*640*60，创建于2013-5-24*/ var cpro_id = "u1290382"; 都是先更新大家先看下，然后等有时间了我给大家给这些代码家注释，所有代码大家可以查看go.lingphp.com我都放在这里了 [php] package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" ) type User struct { id int username, password string } var sqldata map[interface{}]interface{} func main() { var u User db, err := sql.Open("mysql", "ro...阅读全文
logkit是七牛Pandora开发的一个通用的日志收集工具，可以将不同数据源的数据方便的发送到Pandora进行数据分析，除了基本的数据发送功能，logkit还有容错、并发、监控、删除等功能。 logkit详细的文档可以参见[WIKI](https://github.com/qiniu/logkit/wiki)页面。 **支持的数据源** 文件(包括csv格式的文件，kafka-rest日志文件，nginx日志文件等,并支持以[grok](https://www.elastic.co/blog/do-you-grok-grok)的方式解析日志) MySQL Microsoft SQL Server(MS SQL) Elasticsearch MongoDB Kafka R...阅读全文
###### gcache是gorm的中间件，注入后gorm即刻拥有缓存。 ## Overview - 即插即用 - 旁路缓存 - 数据源使用 Redis - 防击穿 - 防穿透 #### 安装 ``` $ go get -u github.com/8treenet/gcache ``` #### 快速使用 ```go import ( "github.com/8treenet/gcache" "github.com/jinzhu/gorm" "github.com/8treenet/gcache/option"" ) func init() { gormdb, _ = gorm.Open("mysql", "") opt := option.DefaultOption{} opt.Expi...阅读全文
摘要： 2017年12月19 -20日，引发全球科技共振的云栖大会在国家会议中心举办2017年的压轴场—北京峰会。在本次大会上，阿里云主力计算平台MaxCompute将全球首次现场完成基于公共云的BigBench评测，并由阿里云总裁胡晓明在20日上午的主论坛宣布最终结果，令人期待。 2017年12月19 -20日，引发全球科技共振的云栖大会在国家会议中心举办2017年的压轴场—北京峰会。在本次大会上，阿里云主力计算平台MaxCompute将全球首次现场完成基于公共云的BigBench评测，并由阿里云总裁胡晓明在20日上午的主论坛宣布最终结果，令人期待。 **什么是BigBench大数据测试基准？** BigBench是基于零售业场景构建的端到端大数据测试基准，支持主流分...阅读全文
老牌数据企业，新兴互联网项目 招聘方向：web后端开发，数据处理 薪资：15-30，团队组建中，有高中低职位，看情况大幅度可调 位置：北京，西四环 联系我！：liuming@id5.c...阅读全文
在用beego查询数据库后经常会 ```go if err != nil { beego.Error(err) } ``` 刚开始学习go，很不知道这里面发生了什么， 1. beego记住了这个error后会做什么，如果web进行一次数据库操作出错了，调用了这个beego.Error(err)，那页面会显示正常页面还是报告error呢。 2. beego记住了这个error后我们怎么在其他地方访问到 3. 还有就是我在models里写了一次这个判断，那么我返回到controller里的时候，还需要写吗？还是我可以在models不写都直接将error返回给controller来处理呢？ 4. 我想翻翻源码，发现太多了，不知道哪个是对头的，应该怎么从源码看起呢。 5....阅读全文
那么 操作系统 会把 CPU的释放 的 功能交给 程序么？ 我越用越不明白啊。 那个 《GO语言编程》里说 GO的并行机制 还不完善。 不是 本人测试。也没有他的测试数据。 是不是 就是因为 操作系统和 语言本身对于 CPU的抢占 有冲突。。 请版主 polaris 给一点 指点。。非常 感谢。...阅读全文
看无闻的Go教程中提到，Go的select对channel的操作，是随机的。我测试的时候，在select中对channel写数据，确实是随机的。但是，我还想证实一下，select对channel的读，也是随机的。下面是一个例子，我通过goroutine，对ch1和ch2两个channel读取数据。为了避免ch1和ch2刚顺序写完就被读出来，影响实验的准确性。我特意在goroutine中使用了timeout。但是我发现两个问题： ①：最终还是先输出ccc，再输出ddd，运行多少次都是一样。我的理解，虽然goroutine后台去执行了，但是休眠5s的过程中，ch1和ch2都已经有值了，那么休眠结束后，理应会随机先输出ccc或者ddd啊 ②：关于timeout，我用sublime的插件...阅读全文
ICMP是用来对网络状况进行反馈的协议，可以用来侦测网络状态或检测网路错误。 限于当前Golang在网络编程方面的代码稀缺，资料甚少，所以分享一个用Golang来构造ICMP数据包并发送ping程序的echo消息的实例。 RFC792定义的echo数据包结构： 0 1 2 3 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | Type | Code | Checksum | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-...阅读全文
最近接手其他同学代码，发现业务功能实现了，但是对于在代码上，利用channel来充当回调函数，导致channel在整个代码中传递来，传递去，看起来相当痛苦，代码维护性也比较糟糕。下面写一些列子来说明这个情况。 示例1：利用channel充当callback package main import ( "fmt" "time" ) func main() { ch := make(chan int) go handleMsg(ch) for index := range ch { fmt.Println(index) } } func handleMsg(ch chan int) { t := time.Tick(time.Second) index := 0 for { select { c...阅读全文
使用Go访问MySQL的方法 安装MySQL驱动 go get github.com/go-sql-driver/mysql 导入mysql包 import ( "database/sql" _ "github.com/go-sql-driver/mysql" ) 连接数据库 db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname") if err != nil { panic(err.Error()) } defer db.Close() err = db.Ping() if err != nil { panic(err.Error()) } 查询 age := 27 rows, err := db.Qu...阅读全文
虽然golang是用C实现的，并且被称为下一代的C语言，但是golang跟C的差别还是很大的。它定义了一套很丰富的数据类型及数据结构，这些类型和结构或者是直接映射为C的数据类型，或者是用C struct来实现。了解golang的数据类型和数据结构的底层实现，将有助于我们更好的理解golang并写出质量更好的代码。 基础类型 源码在：$GOROOT/src/pkg/runtime/runtime.h 。我们先来看下基础类型： /* * basic types */ typedef signed char int8; typedef unsigned char uint8; typedef signed short int16; typedef unsigned short uint16; ty...阅读全文
[Read Go - Channel Tw's blog ][1] 今天主要说说Go中channel的实现机制,其中主要有以下几个部分: Channel的基本数据结构. channel的同步和异步收发. select的实现. [1]: http://totorow.herokuapp.com/posts/672ffcf16d0e907b40b1bcb7bef510f...阅读全文
零、从Release Cycle说起 从Go 1.3版本开始，Golang核心开发Team的版本开发周期逐渐稳定下来。经过Go 1.4、Go1.5和Go 1.6的实践，大神Russ Cox在Go wiki上大致定义了Go Release Cycle的一般流程： 半年一个major release版本。 发布流程启动时间：每年8月1日和次年2月1日（真正发布日期有可能是这个日子，也可能延后几天）。 半年的周期中，前三个月是Active Development，then 功能冻结（大约在11月1日和次年的5月1日）。接下来的三个月为test和polish。 下一个版本的启动计划时间：7月15日和1月15日，版本计划期持续15天，包括讨论这个major版本中要实现的主要功能、要fix的前期遗留的b...阅读全文
各位同仁： 本人初次尝试使用golang进行开发。在用go进行socket对接java服务时需要读取数据流中的各种类型。 java的java.io.DataInputStream类有各种数据读取的实现，如readInt, readFloat, readUTF等。 目前在go中同样实现相应的方法，本人尝试 var x int32 b_buf := bytes.NewBuffer(b) c,_ := b_buf.ReadByte() fmt.Println(c) binary.Read(b_buf, binary.BigEndian, &x) fmt.Println(x) 可以读取int类型的数据。但是针对readUTF这种字符串类型的数据目前还不清楚如...阅读全文
Json的使用基本没有什么难度，就拿Golang来说，直接来个encoding/json包里的func Marshal(v interface{}) ([]byte, error)和func Unmarshal(data []byte, v interface{}) error就能对Json进行编解码了。具体的文件就是采用反射的方法，可以参考我之前的文章『Golang通过反射实现结构体转成JSON数据』。 现在问题来了，如下的map需要大家是如何解析的？ {"10000000000":10000000000,"111":1} 如果直接定义一个map来解析，定义成map[string]int64，我们是肯定可以解析成功的，解析的时候会将数据转换为我们需要的数据类型。那么问题来了：如果把类型定义...阅读全文
昨天在讨论平台新架构的时候，还在说要搞个配置管理的服务出来，方便接口的管理。然后今天就看到了这个……人品爆发了吗？ 好吧，不扯淡，直接翻译 Doozer 的 README 吧。Doozer 我还没实测，不过感觉，如果真得像 README 上面说得那样，还是很有用，很有用的。 关键——这个玩意提供了 go 的接口。（补充一点，忘了说了，这个是用 go 开发的） 项目代码托管于此：Doozer。 ———————-翻译分割线———————- Doozer 这是什么？ Doozer 是高可用的，完整一致性的用于小量、极端重要的数据的存储。当数据变化时，它立刻通知接入的客户端（不缓存），对于那些很少更新，但是希望更新发生时实时性高的客户端来说是非常理想的。Doozer 对于名字服务、主数据库选取和多个...阅读全文
package main import ( "fmt" "compress/zlib" "bytes" ) func main() { var input = []byte("data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAKsAAAAgCAYAAABtn4gCAAAI9klEQVR4Xu2cfYxcVRmHn3Pu3Nm6lXa2ta0AYlsgFSGgThMU0W5hGkqApNGARk3cGm3BRN3FYGuCISrBXaNphcSkG2I3hn9gY2gSNWq32AoE1C6KRihFti2QSgvsTmm783HvOa+zM69cSS8Tacsq7n2SX87cj5P7ZvLs2ztnbseICG8HMjIsbxMyMnIoxhja...阅读全文
背景业务线的活动，每一次新活动都做独立项目开发，有大量重复代码，并且浪费数据服务的连接资源；排序服务也许要经常添加业务代码，目前是停服务发布……这些场景为了开发维护效率、稳定性、安全性和性能都使用了Go语言。Go是静态编译语言，在具体的动态场景该如何实现应用级别的持续交付呢？基于k8s，nginx网关，队列回溯消费等工具的实现也可以实现不同程度的持续交付，但是持续交付的要求越高，搭建平台和维护的成本也越高。从应用开发本身出发，可以考虑插件化。>>>阅读全...阅读全文
go语言中map的数据结构,以下只摘取了关键的几个属性: struct Bucket { uint8 tophash[BUCKETSIZE]; // top 8 bits of hash of each entry (0 = empty) Bucket *overflow; // overflow bucket, if any byte data[1]; // BUCKETSIZE keys followed by BUCKETSIZE values }; struct Hmap { uint8 B; // log_2 of # of buckets (can hold up to LOAD * 2^B items) byte *buckets; // array of 2^B Bucket...阅读全文
为什么要分析gob序列化格式的性能 我自己编的一个单向同步软件(https://gitee.com/rocket049/mysync)，混合了RPC和HTTP服务器功能，利用RPC做控制功能，HTTP进行数据上传。最近我有意简化其构造，把其中的http上传功能也用RPC方式实现。但是我担忧会导致性能下降，因为通常对象序列化，将会导致数据量增加，例如JSON序列化后，二进制数据变成16进制数据，数据量倍增。因此我测试了gob序列化前后的体量变化。 测试方法 我编写了一个小程序，参数是输入文件，把这个文件转换为一个结构体，其中包含文件名(strring)和所有数据组成的数组([]byte)，然后用golang标准库encoding/gob将这个结构体序列化后保存到另一个文件中，然后比较输入文件和...阅读全文
1. [二叉搜索树](https://flaviocopes.com/golang-data-structure-binary-search-tree) 2. [字典](https://flaviocopes.com/golang-data-structure-dictionary) 3. [图](https://flaviocopes.com/golang-data-structure-graph) 4. [哈希表](https://flaviocopes.com/golang-data-structure-hashtable) 5. [链表](https://flaviocopes.com/golang-data-structure-linked-list) 6. [队列](h...阅读全文
实现 主要利用redis的brpop阻塞读和Golang的goroutine并发控制以及os/exec执行程序，实现队列有数据就立即执行对应程序并把结果set任务key。 运行参数 设置brpop的超时(-t)和同步调度时返回的结果ttl(-e) ./dispatchdeploy Usage: -h 192.168.6.151 -p 6388 -t 300 -a /path/testfile.pl -e 1800 -a string start appname (default "/path/testfile.pl") -e int redis expire time sec (default 1800) -h string redis ip -p int redis port (defau...阅读全文
Go语言革命性地在静态开发语言阵营中率先提供了多返回值功能。这个特性让开发者可以从原来用各种比较别扭的方式返回多个值的痛苦中解脱出来，既不用再区分参数列表中哪几个用于输入，哪几个用于输出，也不用再只为了返回多个值而专门定义一个数据结构。 package main import "fmt" func vals() (int, int) { return 3, 7 } func main() { a, b := vals() fmt.Println(a) fmt.Println(b) _, c := vals() fmt.Println(c) } 123456789101112131415 package mainimport "fmt" func vals() (int, int) { ret...阅读全文
A表数据到B表数据，AB在同一个机器，执行机24核服务器，300万行数据历时1m30s 高手分析一下，这个速度是一般，还是极致了，相互学...阅读全文
go反射 什么是反射？使用反射可以实现什么功能？ 反射提供了一种可以操作任意类型数据结构的能力。通过反射你可以实现对任意类型的深度复制，可以对任意类型执行自定义的操作。另外由于golang可以给结构体定义tag熟悉，结合反射，于是就可以实现结构体与数据库表、结构体与json对象之间的相互转换。 使用反射需要注意什么事情？ 使用反射时需要先确定要操作的值是否是期望的类型，是否是可以进行“赋值”操作的，否则reflect包将会毫不留情的产生一个panic。 struct initializer示例 go-struct-initializer 是我在学习golang反射过程中实现的一个可以根据struct tag初始化结构体的go library，这里对其中用到的反射技术做一下说明 package...阅读全文
课程介绍 阿里云消息服务（Message Service，原MQS）是阿里云商用的消息中间件服务。与传统的消息中间件不同，消息服务一开始就是基于阿里云自主研发的飞天分布式系统来设计和实现，具有大规模，高可靠、高并发访问和超强消息堆积能力的特点。消息服务API采用HTTP RESTful标准，接入方便，跨网络能力强；已全面接入资源访问控制服务（RAM）、专有网络（VPC），支持各种安全访问控制；接入云监控，提供完善的监控及报警机制。消息服务提供丰富的SDK、解决方案、最佳实践和7x24小时的技术支持，帮助应用开发者在应用组件之间自由地传递数据和构建松耦合、分布式、高可用系统。 消息服务同时具备发送短信的能力，支持快速发送短信验证码、短信通知、推广短信。完美支撑双11期间的2亿用户发...阅读全文
func （m xxxstruct) insertxxx() (bool,string){ sqlquery :="insert into tables_name(id,name,email,content,) values(%v，%v,%v,%v)" sqlquery =fmt.Sprintf(sqlquery,m.id,m.name,m.email,m.content) ok,desc :=queryexecmysql(sqlquery) if ok { return false,desc } return true,"ok"}func queryexecmysql(parmam string)(bool string){ o :=orm.NewOrm() o.Using("deaful...阅读全文
/*码农网底部横幅*/ var cpro_id = "u1635067"; Go语言目前也比较热门，本文主要来讨论一下Go语言的5大基本数据类型以及其使用方法。Go语言的基本数据类型包括注释、标识符、常量、变量以及布尔值，下面我们逐一来对这些数据类型进行分析。 1、注释(与C++一样) 行注释：//块注释：/* …*/ 2、标识符 可以这么说，除了数字开头的不允许，符号开头的不允许，关键字不允许，其他的Unicode字符组合都可以。“_33”也可以是标识符、“我们”也可以是标识符。标识符也区分大小写。 (1)、以大写字母开头的标识符是公开的。(这个很有意思) (2)、其他任何标识符都是私有的。 (3)、空标识符“_”是一个占位符，用于赋值操作的时候，丢弃、忽略某个值。通常这样用： go的方法...阅读全文
时常会在应用中用到数据库功能，象 Key-Value 性质的。直接搬个 Redis,Mysql嫌大，好在有 LevelDB，直接编进应用中。 有关什么是 LevelDB 以及 LevelDB 的特性，可Google之，我们看看如何用。 先要 go get github.com/syndtr/goleveldb/leveldb 然后在文件中 import 进来。 1.打开数据库 db,err = leveldb.OpenFile("./db",nil) if (err != nil) { panic(err) } 如果这里如果有错，直接报了。 2.然后，读用 db.Get, 写用 db.Put 。 3.代码中的一小段。 package main import ( "github.com/syn...阅读全文
//@description 日志记录工具类 /* 日志格式: 时间(系统时间) 日志类型(方法设置) 日志内容(动态输入) 日志类包含两个同步锁: 缓冲区锁-mu_buf 文件锁-mu_file 日志输入操作 Printf Println 1.获取缓冲区锁 2.写入缓冲区 3.释放缓冲区锁 4.A.调用bufWrite,B.等待定时调用bufWrite 日志输出操作 bufWrite 1.获取文件锁 2.判断缓冲区,不需写入则返回 3.获取缓冲区锁 4.写入缓冲区 5.释放缓冲区锁 日志监听操作 fileMonitor A.文件监听定时器到期fileCheck 1.获取文件锁 2.判断是否需要文件重名,并后续操作 3.释放文件锁 B.定时写入定时器到期bufWrite 文件定时写入bufW...阅读全文
请教各位社区好友，我有一个这样的需求：需要给app提供数据restful的接口，同时向某一个restful接口请求存储到数据库，我的问题是：这样的需求我们用什么插件？什么框架？或者怎么去搭建呢...阅读全文
问题背景 某天打开 Jaeger UI 后，发现里面没有任何数据了，这是个奇怪的问题。 然后立马上服务器检查了 jaeger-collector, jaeger-agent, jaeger-query 和 Elasticsearch 的服务进程、端口及网络通信。所有一切都正常。 然后进一步排查数据流向问题，通过排查 jaeger-collector 日志，发现 jaeger-agent -> jaeger-collector 之间的数据传输没有问题。 而 jaeger-collector -> ES 之间数据传输时报错了。错误如下： {"level":"error","ts":1576483292.2617185,"caller":"config/config.go:130","msg":"...阅读全文
先上代码…… package main import "fmt" func testMap() { //两种声明map方式，切记，必须初始化才能用，否则panic //var a map[string]string = map[string]string{ // "key": "value", //} a := make(map[string]string, 10) a["abc"] = "efg" //map的key是唯一的，修改值可以直接改 a["abc"] = "efg2" a["abc1"] = "efg" fmt.Println(a) } //map嵌套map //map是无序排序 func testMap2() { a := make(map[string]map[string]...阅读全文
 自保险于1384年在佛罗伦萨诞生以来，它对生活的影响从未像本世纪这么大。 2016年1月中旬，阿里云市场上线第一份数据保险——由众安保险提供的数据安全险，为企业虚拟资产数据的安全承保。用户投保后，一旦发生因黑客入侵引发的数据泄露，将由众安保险公司提供最高100万元的现金赔偿，最大限度降低客户损失。这是国内第一份专保黑客盗取云计算数据的保险，意味着DT时代数据的价值正在被各方认可，而保险的推出也将推动企业更广泛地使用云计算。 DT时代，数据已成企业核心资产，而数据的安全则涉及多个环节。 在...阅读全文
使用微号帮渠道二维码生成功能，粉丝通过扫描二维码统计来源，并自动分组。满足企业公众号市场分析，只有已微信认证的服务号才能实现，订阅号没有生成带参数的二维码的权限。1、微信扫码关注自动打标签分组创建渠道二维码》粉丝识别标识》打标签/分组，设置成功后，粉丝扫码关注就会自动打标签分组2、微信扫码关注自动修改粉丝备注创建渠道二维码》粉丝识别标识》修改粉丝备注名，设置成功后，粉丝扫码关注就会自动修改粉丝备注名3、粉丝扫码自动打标签分组数据明细4、渠道粉丝数据统计渠道二维码统计数据表，粉丝微信扫码关注或取关公众号都能统计监测到...阅读全文
golang数据结构之List,实际中用得很少，这里只做研究。 package main import ( "container/list" "github.com/sanity-io/litter" ) type Thing struct { Id int Info string } // golang 双向链表结构 func main() { doubleList := list.New() doubleList.PushBack(&Thing{Id:1, Info:"hello"}) doubleList.PushBack(&Thing{Id:2, Info:"list"}) doubleList.PushBack(&Thing{Id:3, Info:"!"}) //for e := ...阅读全文
版本 golang -- 1.12.4 mongodb -- 4.0 go driver -- 1.0.0 简介 mongodb的数据库driver在官方文档里面明确写明所有的数据库连接需要自己建立和释放，而且建议尽量复用已有的建立，那么也就是说driver里面并未实现连接池的功能。在我们实际应用中就需要自己实现这套数据库连接池提升程序和数据库之间的执行效率。 设计思路 用一个数组来存放数据库连接的指针，并记录每一个指针两个状态: a.是否申请了数据库连接 b.这个连接是否已经给系统在使用中。举个例子就比较好理解了: 申请一个用于存放数据连接的数组，一开始空的什么都没有 pool_initial.png 程序需要一个数据库连接，连接池把数组第一个位置建立一个数据库连接，并把这个连接的状态置为...阅读全文
使用golang的正则表达式实现人民币小写转大写，代码如下： package main import ( "regexp" "strconv" "log" "fmt" ) func ConvertNumToCny(num float64) string { strnum := strconv.FormatFloat(num*100, 'f', 0, 64) sliceUnit := []string{"仟", "佰", "拾", "亿", "仟", "佰", "拾", "万", "仟", "佰", "拾", "元", "角", "分"} // log.Println(sliceUnit[:len(sliceUnit)-2]) s := sliceUnit[len(sliceUnit)-len...阅读全文
**DTLE是一个开源的数据传输中间件**，其针对的核心场景如下: **跨数据中心的数据传输**：DTLE能在数据中心间进行可靠数据传输，并提供链路压缩以降低传输成本 **云间数据同步/迁移**：DTLE能提供在公有云间架设数据同步通道，以支持数据容灾等需求 **数据汇聚**：DTLE能将多个数据源汇聚到同一个数据源，以提供数据分析/数据转储的功能 **数据订阅**：DTLE能将数据源的变更消息发往Kafka等消息中间件，以支持数据订阅通知/缓存失效通知等需求 **跨数据中心的双向复制**：DTLE能在数据中心间提供双向复制通道，以配合业务实现数据双写 **分布式架构**：DTLE在数据传输这个基本场景上，使用了成熟的分布式任务调度架构，可以便捷地在集群中配置大量的数据传...阅读全文
What you are wasting today is tomorrow for those who died yesterday; what you hate now is the future you can not go back. 你所浪费的今天是昨天死去的人奢望的明天； 你所厌恶的现在是未来的你回不去的曾经。 之前用Golang写过一篇关于下载的文章（https://my.oschina.net/90design/blog/1607131）， 最后提到：如果新需求是同时下载，并且按循序下载，最近看到在论坛里有人又再问起，就想起来更新一下此问题。 开始 两个协程交替输出1-20 package main import "fmt" func main() { A := make(c...阅读全文
网上找了下说使用断言的，有谁能帮我解释下...阅读全文
1个serv goroutine需要和5000以上可变数量的client goroutine通过chan通信，client作为send发送数据量较大，请问serv与client能通过chan[ ] string 来通信吗？serv端如何监控这个 chan slice呢？貌似select无法完成？如果只能用一个异步chan来完成，在serv端for range chan时是否能保证一个client所发送消息的有序被处理？性能上有什么好的建议？谢...阅读全文
