安科网

Go语言（二十一） 常见的模块使用

码墨

码墨

2020-06-01

关注 关注
模块使用

执行系统shell命令

  • 使用os/exec模块
package main

import (
   "fmt"
   "os/exec"
)

func main()  {
   var (
      cmd *exec.Cmd
      err error
   )
   cmd = exec.Command("/bin/bash","-c","echo hello")
   err = cmd.Run()
   if err != nil {
      fmt.Println(err)
   }
   fmt.Println(err)
}
  • 获取命令执行的返回结果
package main

import (
   "fmt"
   "os/exec"
)

func main()  {
   var (
      cmd *exec.Cmd
      output []byte
      err error
   )
   //生成cmd
   cmd = exec.Command("/bin/bash","-c","sleep 1;ls -l ~/")
   if output,err = cmd.CombinedOutput();err != nil {
      fmt.Printf("cmd return faild,err:%v\n",err)
      return
   }
   //打印返回结果
   fmt.Printf("%s\n",string(output))
}
  • 多线程
package main

import (
   "context"
   "fmt"
   "os/exec"
   "time"
)

type result struct {
   err error
   output []byte
}

func main() {
   var (
      cmd *exec.Cmd
      ctx context.Context
      cancelFunc context.CancelFunc
      resultChan chan *result
      res *result
   )

   resultChan = make(chan *result,1000)   //创建一个结果队列
   ctx,cancelFunc = context.WithCancel(context.TODO())

   go func() {
      var (
         output []byte
         err error
      )
      cmd = exec.CommandContext(ctx,"/bin/bash","-c","sleep 2;echo hello")
      //执行任务，捕获输出
      output,err = cmd.CombinedOutput()
      //把输出结果输出给main协程
      resultChan <- &result{
         err:   err,
         output: output,
      }
   }()

   //1秒取消上下文
   time.Sleep(time.Second*3)
   //取消上下文
   cancelFunc()
   //在main协程里等待子协程的退出，并打印任务执行的结果
   res = <- resultChan
   fmt.Println(res.err,string(res.output))
   //fmt.Printf("err=%v,res=%s\n",res.err,string(res.output))
}

cron模块的使用

  • 执行单个任务
package main

import (
   "fmt"
   "github.com/gorhill/cronexpr"
   "time"
)

func main() {
   var (
      expr *cronexpr.Expression
      err error
   )
   //每分钟执行一次
   /*
   if expr,err = cronexpr.Parse("* * * * *");err != nil {
      fmt.Println(err)
      return
   }
   */
   //每五秒执行一次，支持到年的配置
   if expr,err = cronexpr.Parse("*/5 * * * * * *");err != nil {
      fmt.Println(err)
      return
   }
   //获取当前时间
   now := time.Now()
   //下次执行时间
   nextTime := expr.Next(now)
   //等待这个定时器超时
   time.AfterFunc(nextTime.Sub(now), func() {
      fmt.Println("被调度了：",nextTime)
   })

   time.Sleep(time.Second*5)
}
  • 执行多个任务
package main

import (
   "fmt"
   "github.com/gorhill/cronexpr"
   "time"
)

type CronJob struct {
   expr *cronexpr.Expression
   nextTime time.Time
}

func main() {
   //需要一个调度协程，定时检查所有的cron任务，谁过期执行谁
   var (
      cronJob *CronJob
      expr *cronexpr.Expression
      now time.Time
      scheduleTable map[string]*CronJob
   )

   scheduleTable = make(map[string]*CronJob)    //初始化调度表
   //获取当前时间
   now = time.Now()
   // 1.定义两个cron
   expr = cronexpr.MustParse("*/5 * * * * * *")
   cronJob = &CronJob{
      expr:     expr,
      nextTime: expr.Next(now),
   }
   //将任务1注册到调度表
   scheduleTable["job1"] = cronJob
   // 2.定义两个cron
   expr = cronexpr.MustParse("*/5 * * * * * *")
   cronJob = &CronJob{
      expr:     expr,
      nextTime: expr.Next(now),
   }
   //将任务1注册到调度表
   scheduleTable["job2"] = cronJob
   //启动一个调度协程
   go func() {
      var(
         jobName string
         cronJob *CronJob
         now time.Time
      )
      //定期检查调度表
      for {
         now = time.Now()
         for jobName,cronJob = range scheduleTable {
            //判断是否过期
            if cronJob.nextTime.Before(now) || cronJob.nextTime.Equal(now) {
               //启动一个协程，执行这个任务
               go func(jobName string) {
                  fmt.Println("执行:",jobName)
               }(jobName)
            }
            //计算下一次的调度时间
            cronJob.nextTime = cronJob.expr.Next(now)
            fmt.Println(jobName,"下次执行的时间:",cronJob.nextTime)
         }
      }
      //睡眠100毫秒，进入下一次循环
      select {
      case <- time.NewTimer(100*time.Millisecond).C: //将在100毫秒可读，返回
      }
   }()
   time.Sleep(100*time.Second)
}

etcd的使用

  • 与etcd建立连接
package main

import (
   "fmt"
   "github.com/coreos/etcd/clientv3"
   "time"
)
func main()  {
   var (
      config clientv3.Config
      client *clientv3.Client
      err error
   )
   //客户端配置
   config = clientv3.Config{
      Endpoints:            []string{"192.168.56.11：2379"},
      DialTimeout:          5*time.Second,
   }
   //建立连接
   if client,err = clientv3.New(config);err != nil {
      fmt.Println(err)
      return
   }
   client = client
}
  • 插入键值对
package main

import (
   "context"
   "fmt"
   "github.com/coreos/etcd/clientv3"
   "time"
)

func main() {
   var (
      config clientv3.Config
      client *clientv3.Client
      err error
      kv clientv3.KV
      putResp *clientv3.PutResponse
   )
   //建立连接
   config = clientv3.Config{
      Endpoints:            []string{"192.168.56.11:2379"},
      DialTimeout:          5*time.Second,
   }

   if client,err = clientv3.New(config);err!=nil {
      fmt.Println(err)
      return
   }

   //读写etcd的键值对
   kv = clientv3.NewKV(client)
   //kv.Put(ctx context.Context())
   if putResp,err = kv.Put(context.TODO(),"/cron/jobs/job1","hello",clientv3.WithPrefix());err != nil {
      fmt.Println(err)
      return
   }else {
      fmt.Println(putResp.Header.Revision)
      if putResp.PrevKv != nil {
         fmt.Println("PrevValue:",string(putResp.PrevKv.Value))
      }
   }
}
  • 读写etcd键值对
package main

import (
   "context"
   "fmt"
   "github.com/coreos/etcd/clientv3"
   "time"
)

func main() {
   var (
      config  clientv3.Config
      client  *clientv3.Client
      err     error
      kv      clientv3.KV
      getResp *clientv3.GetResponse
   )
   //建立连接
   config = clientv3.Config{
      Endpoints:   []string{"192.168.56.11:2379"},
      DialTimeout: 5 * time.Second,
   }

   //建立客户端
   if client, err = clientv3.New(config); err != nil {
      fmt.Println(err)
      return
   }
   //用于读写etcd键值对
   kv = clientv3.NewKV(client)

   if getResp,err = kv.Get(context.TODO(),"/cron/jobs/job1",/*clientv3.WithCountOnly())*/);err !=nil {
      fmt.Println(err)
      return
   }else {
      fmt.Println(getResp.Kvs,getResp.Count)
   }
}
  • 按目录读取键值对
package main

import (
   "context"
   "fmt"
   "github.com/coreos/etcd/clientv3"
   "time"
)

//按目录获取
func main() {
   var (
      config  clientv3.Config
      client  *clientv3.Client
      err     error
      kv      clientv3.KV
      getResp *clientv3.GetResponse
   )
   //建立连接
   config = clientv3.Config{
      Endpoints:   []string{"192.168.56.11:2379"},
      DialTimeout: 5 * time.Second,
   }

   //建立客户端
   if client, err = clientv3.New(config); err != nil {
      fmt.Println(err)
      return
   }
   //用于读写etcd键值对
   kv = clientv3.NewKV(client)
   //取/cron/jobs/为前缀的所有key
   if getResp,err = kv.Get(context.TODO(),"/cron/jobs",clientv3.WithPrefix());err != nil {
      fmt.Println(err)
      return
   }else {
      //获取所有的kvs
      fmt.Println(getResp.Kvs)
   }
}

go语言 context

码墨

码墨

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

详解Go语言中用 os/exec 执行命令的五种方法

在 Golang 中用于执行命令的库是 os/exec，exec.Command 函数返回一个 Cmd 对象，根据不同的需求，可以将命令的执行分为三种情况。直接调用 Cmd 对象的 Run 函数，返回的只有成功和失败，获取不到任何输出的结果。Combine

小科的奋斗 2020-11-16

关于go语言编码需要放到src 文件夹下的问题

配置GOPATH的用意是为了方便项目的部署和构建，以及可以直接使用go get 命令下载第三方的包到自己的项目的src下和相关的执行文件bin目录，和中间文件pkg. 问1：index entire GOPATH:如果你选中那么我就把你在环境变量中配置的G

wfs 2020-10-29

GO语言gin框架实现管理员认证登陆接口

后台用户登录验证功能是很多项目的必须要有的逻辑 , 也是常见的技术需求 .

hellosunshine 2020-10-27

Go语言实现猜数字小游戏

利用Go语言实现一个四位数字，而且不重复的猜数字游戏，解题思路是先利用rand随机函数产生一个四位数，然后通过切片进行引用传递，设定用户可以输入的数字，最后分别遍历切片四位数字与产生的四位数是否相同。break //跳出最外层循环。randSlice:=m

哈嘿Blog 2020-10-26

一篇文章带你了解Go语言基础之指针

作为21世纪的C语言，Go可能多方面思考，最终还是保留了指针。因为Go语言是类C语言，所以为了提高效率，仍然保留了指针。但是如果没有接触过指针，可能学起来指针需要多多思考一下了。指针通常情况下，也被称为小白劝退神奇。栈内存在存储上，只能存一些简单的东西，比

bearhoopIT之道 2020-11-11

属于新十年的开发语言：Go语言可能很快会取代Python

30年前，Python首次亮相，它花了20年才得到开发者的赞赏。如今，它已经成为开发者第二喜爱的语言。尤其是在过去五年里，Python用户激增，成为机器学习和数据科学开发者的首选语言。在未来几年里，Python在这些领域的主导地位必然是很难被动摇的。但与较

文山羊 2020-11-07

一篇文章带你了解Go语言基础之函数（上篇）

Hey，大家好呀，我是星期八，这次咱们继续学习Go基础之函数叭。函数，在所有编程语言中都叫函数，Java，PHP，Python，JS等，统一都叫函数。一般是这样形容的:函数可以将重复的，或者特定功能的，封装成一个方便调用的东西。函数命名尽量以驼峰命名，例如

jaminliu0 2020-10-25

Go语言在极小硬件上的运用（二）

在本文的第一部分的结尾，我承诺要写关于接口的内容。我不想在这里写有关接口或完整或简短的讲义。相反，我将展示一个简单的示例，来说明如何定义和使用接口，以及如何利用无处不在的io.Writer接口。还有一些关于反射reflection和半主机semihosti

railssky 2020-10-25

Go语言在极小硬件上的运用（一）

Go 语言，能在多低下的配置上运行并发挥作用呢？我购买它的理由有三个。首先，我从未接触过 STM320 系列的开发板。其次，STM32F10x 系列使用也有点少了。STM320 系列的 MCU 很便宜，有更新一些的外设，对系列产品进行了改进，问题修复也

小科的奋斗 2020-10-24

一篇文章带你了解Go语言基础之字节类型

Hey，大家好呀，我是星期八，这次咱们继续学习Go基础之字节类型吧。可以看到，在Go中，字符串其实就是指向了一个连续的内存地址，并且记录了长度，读取是一次性读取出来的。字符串是一个个字符拼接成的，反过来，也是一个个字符拼接成的字符串，而一个个的字符，就被称

HELLOBOY 2020-10-23

一篇文章带你了解Go语言基础之变量

Hey，大家好呀，我是星期八，这次咱们继续学习Go基础之变量叭。简单点说，我们写的程序默认数据都是保存在内存条中的，我们不可能直接通过地址找到这个变量，因为地址太长了，而且不容易记。通常我们是通过变量名找到对应的地址上面的值，再进行一系列操作。现在不管是什

牧 2020-10-22

一篇文章带你了解Go语言基础之数组

Hey，大家好呀，我是星期八，这次咱们继续学习Go基础之数组扒。//fmt.Println//结果:[0000000000]声明不赋值，int类型默认是0，其他类型也有默认值。//varname_list=[...]int{1，2，4，5，19}//...

狼窝 2020-10-22

专为人工智能和数据科学而生的Go语言，或将取代Python

时间回到30年前，Python 首次亮相。花了20年时间，Python才获得开发者的认可。来到 2019 年，Python已经成为开发人员第二喜欢的语言。在过去的5年时间里，Python 成为了机器学习和数据科学开发人员的首选编程语言。可以预见的是，在未

ciqingloveless 2020-10-15

Go语言酷的一些东西

Go是一种相对较新的语言，由Google的Robert Griesemer，Rob Pike和Ken Thompson于2009年之前创建。它是开源的，因此任何人都可以为此做出贡献并提出新功能。替代C ++似乎主要是为了使Google的软件工程师的工作更

专注前端开发 2020-10-12

Go语言使用swagger生成接口文档的方法

Swagger本质上是一种用于描述使用JSON表示的RESTful API的接口描述语言。Swagger与一组开源软件工具一起使用，以设计、构建、记录和使用RESTful Web服务。Swagger包括自动文档，代码生成和测试用例生成。可是编写接口文档历来

哈嘿Blog 2020-09-08

Go语言中如何通过方法为类型添加行为

数十年以来， 传统的面向对象语言总是说方法属于类， 但 Go 不是这样做的: 它提供了方法， 但是并没有提供类和对象。乍一看， 这种做法似乎有些奇怪， 甚至可以说有点儿疯狂， 但实际上 Go 的方法比以往其他语言的方法都要灵活。我们可以将方法与同一个包中声

linmufeng 2020-09-08

Go语言文件读取的一些总结

最常见的比如直接对文件本身进行Read和Write； 除此之外，还可以使用bufio库的流式处理以及分片式处理；如果文件较小，使用ioutil也不失为一种方法。面对这么多的文件处理的方式，那么初学者可能就会有困惑：我到底该用那种？它们之间有什么区别？笔者试

qidiantianxia 2020-09-15

详解Go语言中关于包导入必学的 8 个知识点

在 Go 语言中，一个包可包含多个 .go 文件，只要这些 .go 文件的头部都使用 package 关键字声明了同一个包。如你所见，Go 语言中 导入的包，必须得用双引号包含，在这里吐槽一下。防止导入的包名和本地的变量发生冲突，比如 path 这个很常用

哈嘿Blog 2020-08-16

GO语言实现标题闪烁效果

因为聊天框是被iframe框进去的页面,所以在聊天框中收到websocket消息以后要把消息发送给父集页面,在父页面中闪烁标题

wfs 2020-08-16

Go语言实现基于websocket浏览器通知功能

当我们使用了websocket技术实现了实时的推送访客来到消息,但是我们只能随时看着页面不离开才能知道有访客来到。现在增加浏览器的通知消息,就可以只要打开着界面,不用一直盯着,干别的事去就可以了,有新消息会从右下角弹出来。notification = ne

蓝色深海 2020-08-16
码墨

码墨

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号