首页 > 其他分享 >GO实现分布式爬虫—掌握go语言通道与协程项目架构设计

GO实现分布式爬虫—掌握go语言通道与协程项目架构设计

时间:2023-11-11 12:11:23浏览次数:40  
标签:架构设计 协程 string err fmt Println user go name

GO实现分布式爬虫—掌握go语言通道与协程项目架构设计

Go高并发微服务分布式 

1.命令行的用户管理

 用户信息存储

        => 内存

        => 结构 [] map

        => 用户 ID name age tel addr

                        [len] [] map

                        值类型使用string

用户添加

用户的查询

 

用户修改

        // 请输入需要修改的用户ID:

        // users[id] => 在 不在(你输入的用户ID不正确)

        // 打印用户信息,提示用户是否确认修改(Y/N)

        // Y 提示用户输入修改后内容

        // name, age, tel, addr

用户删除

        // 请输入需要删除的用户ID:

        // users[id] => 在 不在(你输入的用户ID不正确)

        // 打印用户信息,提示用户是否确认删除(Y/N)

        // Y delete()

        // name, age, tel, addr

用户登录:

        在程序中定义PASSWORD = "zzzzzzzz"

        提示输入密码,如果密码输出3次都失败,提示并退出

        如果密码成功,再进行用户管理操作

users.go

  1.   package main
  2.    
  3.   import (
  4.   "fmt"
  5.   "strconv"
  6.   "strings"
  7.   )
  8.    
  9.   // 添加用户
  10.   func add(pk int, users map[string]map[string]string) {
  11.   var (
  12.   // id string = fmt.Sprintf("%d", pk)
  13.   id string = strconv.Itoa(pk)
  14.   name string
  15.   age string
  16.   tel string
  17.   addr string
  18.   )
  19.   fmt.Print("请输入姓名:")
  20.   fmt.Scan(&name)
  21.    
  22.   fmt.Print("请输入年龄:")
  23.   fmt.Scan(&age)
  24.    
  25.   fmt.Print("请输入电话:")
  26.   fmt.Scan(&tel)
  27.    
  28.   fmt.Print("请输入地址:")
  29.   fmt.Scan(&addr)
  30.    
  31.   users[id] = map[string]string{
  32.   "id": id,
  33.   "name": name,
  34.   "tel": tel,
  35.   "addr": addr,
  36.   }
  37.   fmt.Println(id, name, age, tel, addr)
  38.   }
  39.    
  40.   // 查询用户
  41.   // q == "" 显示全部
  42.   // 非空,名称,电话,住址任意一个属性中包含q内容的显示
  43.   func query(users map[string]map[string]string) {
  44.   var q string
  45.    
  46.   fmt.Print("请输入查询信息:")
  47.   fmt.Scan(&q)
  48.   title := fmt.Sprintf("%5s|%20s|%5s|%20s|%50s", "ID", "Name", "Age", "Tel", "Addr")
  49.   fmt.Println(title)
  50.   fmt.Println(strings.Repeat("-", len(title)))
  51.   for _, user := range users {
  52.   if q == "" || strings.Contains(user["name"], q) || strings.Contains(user["age"], q) || strings.Contains(user["tel"], q) || strings.Contains(user["addr"], q) {
  53.   fmt.Printf("%5s|%20s|%5s|%20s|%50s", user["id"], user["name"], user["age"], user["tel"], user["addr"])
  54.   fmt.Println()
  55.   }
  56.   }
  57.   }
  58.   func main() {
  59.   // 存储用户信息
  60.   users := make(map[string]map[string]string)
  61.   id := 0
  62.   fmt.Println("欢迎使用个人用户管理系统")
  63.   for {
  64.   var op string
  65.   fmt.Print(`
  66.   1. 新建用户
  67.   2. 修改用户
  68.   3. 删除用户
  69.   4. 查询用户
  70.   5. 退出
  71.   请输入指令:`)
  72.   fmt.Scan(&op)
  73.    
  74.   if op == "1" {
  75.   id++
  76.   add(id, users)
  77.   } else if op == "2" {
  78.    
  79.   } else if op == "3" {
  80.    
  81.   } else if op == "4" {
  82.   query(users)
  83.   } else if op == "5" {
  84.   break
  85.   } else {
  86.   fmt.Println("指令错误")
  87.   }
  88.   }
  89.   }
  1.   package main
  2.    
  3.   import (
  4.   "fmt"
  5.   "os"
  6.   "strconv"
  7.   "strings"
  8.   )
  9.    
  10.   const (
  11.   maxAUTH = 3
  12.   password = "******"
  13.   )
  14.    
  15.   func inputString(prompt string) string {
  16.   var input string
  17.   fmt.Print(prompt)
  18.   fmt.Scan(&input)
  19.   return strings.TrimSpace(input)
  20.   }
  21.    
  22.   // 从命令行输入密码,并进行验证
  23.   // 通过返回值告知验证成功还是失败
  24.   func auth() bool {
  25.   var input string
  26.   for i := 0; i < maxAUTH; i++ {
  27.   fmt.Print("请输入密码:")
  28.   fmt.Scan(&input)
  29.   if password == input {
  30.   return true
  31.   } else {
  32.   fmt.Println("密码错误")
  33.   }
  34.   }
  35.   return false
  36.   }
  37.   func query(users map[int]map[string]string) {
  38.   // var q string
  39.   // fmt.Print("请输入查询内容:")
  40.   // fmt.Scan(&q)
  41.   q := inputString("请输入查询内容:")
  42.   fmt.Println("============")
  43.   for k, v := range users {
  44.   // id, name, birthday, tel, addr, desc
  45.   if strings.Contains(v["name"], q) || strings.Contains(v["tel"], q) || strings.Contains(v["addr"], q) || strings.Contains(v["desc"], q) {
  46.   // fmt.Println(k, v)
  47.   printUser(k, v)
  48.   fmt.Println("--------------")
  49.   }
  50.   }
  51.   fmt.Println("============")
  52.    
  53.   }
  54.    
  55.   func printUser(pk int, user map[string]string) {
  56.   fmt.Println("ID:", pk)
  57.   fmt.Println("名字:", user["name"])
  58.   fmt.Println("出生日期:", user["birthday"])
  59.   fmt.Println("联系方式:", user["tel"])
  60.   fmt.Println("联系地址:", user["addr"])
  61.   fmt.Println("备注:", user["desc"])
  62.    
  63.   }
  64.   func getId(users map[int]map[string]string) int {
  65.   var id int
  66.   for k := range users {
  67.   if id < k {
  68.   id = k
  69.   }
  70.   }
  71.   return id + 1
  72.   }
  73.    
  74.   func inputUser() map[string]string {
  75.   user := map[string]string{}
  76.   user["name"] = inputString("请输入名字:")
  77.   user["birthday"] = inputString("请输入出生日期(2000-01-01):")
  78.   user["tel"] = inputString("请输入联系方式:")
  79.   user["addr"] = inputString("请输入联系地址:")
  80.   user["desc"] = inputString("请输入备注:")
  81.   return user
  82.   }
  83.   func add(users map[int]map[string]string) {
  84.   id := getId(users)
  85.    
  86.   // name := inputString("请输入名字:")
  87.   // birthday := inputString("请输入出生日期(2000-01-01):")
  88.   // tel := inputString("请输入联系方式:")
  89.   // addr := inputString("请输入联系地址:")
  90.   // desc := inputString("请输入备注:")
  91.   user := inputUser()
  92.   // users[id] = map[string]string{
  93.   // "name": name,
  94.   // "birthday": birthday,
  95.   // "tel": tel,
  96.   // "addr": addr,
  97.   // "desc": desc,
  98.   // }
  99.   users[id] = user
  100.   fmt.Println("[+]添加成功")
  101.   }
  102.    
  103.   func modify(users map[int]map[string]string) {
  104.   idString := inputString("请修改用户ID:")
  105.   if id, err := strconv.Atoi(idString); err == nil {
  106.   if user, ok := users[id]; ok {
  107.   fmt.Println("请修改的用户信息:")
  108.   fmt.Println(user)
  109.   input := inputString("确定修改(Y/N)?")
  110.   if input == "y" || input == "Y" {
  111.   // user := map[string]string{}
  112.   // user["name"] = inputString("请输入名字:")
  113.   // user["birthday"] = inputString("请输入出生日期(2000-01-01):")
  114.   // user["tel"] = inputString("请输入联系方式:")
  115.   // user["addr"] = inputString("请输入联系地址:")
  116.   // user["desc"] = inputString("请输入备注:")
  117.   user := inputUser()
  118.   users[id] = user
  119.   fmt.Println("[+]修改成功")
  120.   }
  121.   } else {
  122.   fmt.Println("[-]用户ID不存在")
  123.   }
  124.   } else {
  125.   fmt.Println("[-]输入ID不正确")
  126.   }
  127.   }
  128.    
  129.   func del(users map[int]map[string]string) {
  130.   idString := inputString("请删除的用户ID:")
  131.   if id, err := strconv.Atoi(idString); err == nil {
  132.   if user, ok := users[id]; ok {
  133.   fmt.Println("将删除的用户信息:")
  134.   fmt.Println(user)
  135.   input := inputString("确定修改(Y/N)?")
  136.   if input == "y" || input == "Y" {
  137.   // user := map[string]string{}
  138.   // user["name"] = inputString("请输入名字:")
  139.   // user["birthday"] = inputString("请输入出生日期(2000-01-01):")
  140.   // user["tel"] = inputString("请输入联系方式:")
  141.   // user["addr"] = inputString("请输入联系地址:")
  142.   // user["desc"] = inputString("请输入备注:")
  143.   delete(users, id)
  144.   fmt.Println("[+]删除成功")
  145.   }
  146.   } else {
  147.   fmt.Println("[-]用户ID不存在")
  148.   }
  149.   } else {
  150.   fmt.Println("[-]输入ID不正确")
  151.   }
  152.   }
  153.   func main() {
  154.    
  155.   if !auth() {
  156.   fmt.Printf("[-]密码%d次错误,程序退出\n", maxAUTH)
  157.   return
  158.   }
  159.    
  160.   menu := `*********************
  161.   1. 查询
  162.   2. 添加
  163.   3. 修改
  164.   4. 删除
  165.   5. 退出
  166.   *********************`
  167.    
  168.   // id, name, birthday, tel, addr, desc
  169.   // users := map[int][5]string
  170.   // users := map[int][]string
  171.   // users := []map[string]string{}
  172.   // users := [][]string{}
  173.   // users := [][5]string{}
  174.    
  175.   users := map[int]map[string]string{}
  176.    
  177.   callbacks := map[string]func(map[int]map[string]string){
  178.   "1": query,
  179.   "2": add,
  180.   "3": modify,
  181.   "4": del,
  182.   "5": func (map[int]map[string]string) {
  183.   os.Exit(1)
  184.   },
  185.   }
  186.   // var id int
  187.   fmt.Println("欢迎进入个人的用户管理系统")
  188.   // END:
  189.   for {
  190.   fmt.Println(menu)
  191.   // var op string
  192.   // fmt.Print("请输入指令")
  193.   // fmt.Scan(&op)
  194.   op := inputString("请输入指令:")
  195.   callbacks, ok := callbacks[op]
  196.   if ok {
  197.   callbacks(users)
  198.   // } else if op == "5" {
  199.   // break
  200.   } else {
  201.   fmt.Println("指令错误")
  202.   }
  203.   // switch op {
  204.   // case "1":
  205.   // query(users)
  206.   // case "2":
  207.   // // id++
  208.   // // add(users, id)
  209.   // add(users)
  210.   // case "3":
  211.   // modify(users)
  212.   // case "4":
  213.   // del(users)
  214.   // case "5":
  215.   // break END
  216.   // default:
  217.   // fmt.Println("指令错误")
  218.   // }
  219.   }
  220.   }

2.多用户命令行聊天室

go协程、管道、socket

1) net net 包提供了对 socket 编程的支持, socket 编程分服务端和客户端编程,针对服务端可使用 函数 Listen 创建监听服务,对于客户端可使用函数 Dial 连接服务器   c) 功能 ⚫ TCP 服务端开发流程 ➢ 创建监听服务 ➢ 循环接受客户端连接 ➢ 数据处理(向客户端发送数据 / 读客户端发送的数据) ➢ 关闭监听服务 // 监听 0.0.0.0:9999 端口 // 等待客户端连接 //当客户端连接完成后,给客户端发送一个当前时间 //关闭客户端连接

tcp\server.go

服务器处理任意客户端请求 for{}

  1.   func main() {
  2.   addr := "0.0.0.0:9999"
  3.   listener, err := net.Listen("tcp", addr)
  4.   if err != nil {
  5.   fmt.Println(err)
  6.   os.Exit(-1)
  7.   }
  8.   defer listener.Close()
  9.   fmt.Println("Listen: ", addr)
  10.    
  11.   for {
  12.   client, err := listener.Accept()
  13.   if err == nil {
  14.   client.Write([]byte(time.Now().Format("2006-01-02 15:04:05")))
  15.   client.Close()
  16.   }
  17.   }
  18.    
  19.   }
  1.   package main
  2.    
  3.   import (
  4.   "bufio"
  5.   "fmt"
  6.   "net"
  7.   "os"
  8.   "time"
  9.   )
  10.    
  11.   func main() {
  12.   addr := ":9999"
  13.    
  14.   // 启动监听服务
  15.   server, err := net.Listen("tcp", addr)
  16.   if err != nil {
  17.   fmt.Println(err)
  18.   os.Exit(-1)
  19.   }
  20.    
  21.   // 延迟关闭服务
  22.   defer server.Close()
  23.   fmt.Printf("Listen on: %s\n", server.Addr())
  24.    
  25.   for {
  26.   // 获取客户端连接
  27.   conn, err := server.Accept()
  28.   if err == nil {
  29.   // 使用协程处理与客户端连接
  30.   go func(conn net.Conn) {
  31.   defer conn.Close() // 延迟关闭客户端连接
  32.    
  33.   fmt.Println("client is connected: %s\n", conn.RemoteAddr())
  34.    
  35.   // 读取客户端发送的消息
  36.   reader := bufio.NewReader(conn)
  37.   cxt, _, _ := reader.ReadLine()
  38.   fmt.Println(string(cxt))
  39.    
  40.   // 向客户端发送消息
  41.   fmt.Fprintf(conn, "Time: %s\n", time.Now().Format("2006-01-02 15:04:05"))
  42.   }(conn)
  43.   }
  44.   }
  45.   }
服务器可以接收客户端消息,也可以向客户端发送消息  
  1.   // server.go
  2.   package main
  3.    
  4.   import (
  5.   "bufio"
  6.   "fmt"
  7.   "net"
  8.   "os"
  9.   "strings"
  10.   )
  11.    
  12.   func main() {
  13.   addr := "0.0.0.0:9999"
  14.   listener, err := net.Listen("tcp", addr)
  15.   if err != nil {
  16.   fmt.Println(err)
  17.   os.Exit(-1)
  18.   }
  19.   defer listener.Close()
  20.   fmt.Println("Listen: ", addr)
  21.    
  22.   input := bufio.NewScanner(os.Stdin)
  23.    
  24.   for {
  25.   client, err := listener.Accept()
  26.   if err == nil {
  27.   reader := bufio.NewReader(client)
  28.   writer := bufio.NewWriter(client)
  29.    
  30.   fmt.Printf("客户端%s连接成功\n", client.RemoteAddr())
  31.    
  32.   for {
  33.   fmt.Print("请输入(q退出):")
  34.   input.Scan()
  35.   text := input.Text()
  36.   if text == "q" {
  37.   break
  38.   }
  39.   _, err := writer.WriteString(text + "\n")
  40.   writer.Flush()
  41.   if err != nil {
  42.   break
  43.   }
  44.    
  45.   line, err := reader.ReadString('\n')
  46.   if err != nil {
  47.   break
  48.   }
  49.   fmt.Println("客户端:", strings.TrimSpace(line))
  50.   }
  51.    
  52.   fmt.Printf("客户端%s关闭\n", client.RemoteAddr())
  53.   client.Close()
  54.   }
  55.   }
  56.    
  57.   }
  58.   // client.go
  59.   package main
  60.    
  61.   import (
  62.   "bufio"
  63.   "fmt"
  64.   "net"
  65.   "os"
  66.   )
  67.    
  68.   func main() {
  69.   addr := "127.0.0.1:9999"
  70.   conn, err := net.Dial("tcp", addr)
  71.   if err != nil {
  72.   fmt.Println(err)
  73.   os.Exit(-1)
  74.   }
  75.   defer conn.Close()
  76.    
  77.   reader := bufio.NewReader(conn)
  78.   writer := bufio.NewWriter(conn)
  79.    
  80.   input := bufio.NewScanner(os.Stdin)
  81.    
  82.   for {
  83.   line, err := reader.ReadString('\n')
  84.   if err != nil {
  85.   break
  86.   }
  87.   fmt.Print("服务器:", line)
  88.   fmt.Print("请输入(q退出):")
  89.   input.Scan()
  90.   if input.Text() == "q" {
  91.   break
  92.   }
  93.   _, err = writer.WriteString(input.Text() + "\n")
  94.   writer.Flush()
  95.   if err != nil {
  96.   break
  97.   }
  98.    
  99.   }
  100.    
  101.   }

TCP 客户端开发流程

➢ 连接服务器 ➢ 数据处理(向服务端发送数据 / 读服务端发送的数据) ➢ 关闭连接  

tcp\client.go

  1.   package main
  2.    
  3.   import (
  4.   "bufio"
  5.   "fmt"
  6.   "net"
  7.   "os"
  8.   "time"
  9.   )
  10.    
  11.   func main() {
  12.   addr := "localhost:9999"
  13.    
  14.   // 创建连接
  15.   conn, err := net.Dial("tcp", addr)
  16.   if err != nil {
  17.   fmt.Println(err)
  18.   os.Exit(-1)
  19.   }
  20.    
  21.   // 延迟关闭连接
  22.   defer conn.Close()
  23.    
  24.   // 向服务器发送消息
  25.   fmt.Fprintf(conn, "UnixTime: %d\n", time.Now().Unix())
  26.    
  27.   // 读取服务端发送的消息
  28.   reader := bufio.NewReader(conn)
  29.   cxt, _, _ := reader.ReadLine()
  30.   fmt.Println(string(cxt))
  31.   }

正则

matchstring.go

  1.   package main
  2.    
  3.   import (
  4.   "fmt"
  5.   "regexp"
  6.    
  7.   _ "github.com/go-sql-driver/mysql"
  8.   )
  9.    
  10.   func main() {
  11.   // . 任意
  12.   // \d 数字 \D非数字
  13.   // \w 数字,大小写英文字母 _
  14.   // \S 非空白字符 \s非空白字符
  15.   // \d 数字 0,1,2,3,4,5,6,7,8,9 0|1|2|3|4|5|6|7|8|9 [0123456789] [0-9]
  16.   // [a-z] /a, -, z/ [a\-z]
  17.   // [^a-z] 取反
  18.   // ? 0个或1个
  19.   // + 至少1个
  20.   // * 任意多个
  21.   // {n,m} 字符串数量>=n, <=m
  22.   var pattern string = "^132" // 以132开头
  23.   fmt.Println(regexp.MatchString(pattern, "132xxx"))
  24.   fmt.Println(regexp.MatchString(pattern, "122xxxx"))
  25.   // 以132开头,都是数字,长度为11位 [0-9]
  26.   pattern = "^132\\d{8}$"
  27.   fmt.Println(regexp.MatchString(pattern, "132xxxx"))
  28.   fmt.Println(regexp.MatchString(pattern, "132123123"))
  29.   fmt.Println(regexp.MatchString(pattern, "13212312323"))
  30.   fmt.Println(regexp.MatchString(pattern, "13212312323x"))
  31.   // 132 158
  32.   // 1[35][28] 132 138 152 158
  33.   // 分组 ()
  34.   // ^(132)|(158)[0-9]{8}$
  35.   // 邮箱格式
  36.   // [email protected]
  37.   // xxxx(@之前) 数字,大小写英文字母长度1-32个字符
  38.   // xxx(.之前) 小写英文字母组成 长度1-12字符
  39.   // xx(.之后) edu
  40.   // [a-zA-Z0-9]{1,32}@[a-z]{1,12}.edu
  41.   fmt.Println("----email----")
  42.   //[.]
  43.   pattern = "[a-zA-Z0-9]{1,32}@[a-z]{1,12}\\.edu"
  44.   pattern = "^[a-zA-Z0-9]{1,32}@[a-z]{1,12}[.]edu$"
  45.    
  46.   fmt.Println(regexp.MatchString(pattern, "[email protected]")) // 可以匹配
  47.   fmt.Println(regexp.MatchString(pattern, "[email protected]")) // 不匹配
  48.   fmt.Println(regexp.MatchString(pattern, "[email protected]")) // 不匹配
  49.   fmt.Println(regexp.MatchString(pattern, "a@bxedu")) // 不匹配
  50.   fmt.Println(regexp.MatchString(pattern, "我是[email protected]")) // 不匹配
  51.    
  52.   pattern = regexp.QuoteMeta("^ab")
  53.    
  54.   fmt.Println(regexp.MatchString(pattern, "ab"))
  55.   fmt.Println(pattern)
  56.   fmt.Println(regexp.MatchString(pattern, "^ab"))
  57.   }
  1.   PS D:\Workspace\Go\src\projects\todolist> go run matchstring.go
  2.   true <nil>
  3.   false <nil>
  4.   false <nil>
  5.   false <nil>
  6.   true <nil>
  7.   false <nil>
  8.   ----email----
  9.   true <nil>
  10.   false <nil>
  11.   false <nil>
  12.   false <nil>
  13.   false <nil>
  14.   false <nil>
  15.   \^ab
  16.   true <nil>

regexp.go

  1.   package main
  2.    
  3.   import (
  4.   "fmt"
  5.   "regexp"
  6.    
  7.   _ "github.com/go-sql-driver/mysql"
  8.   )
  9.    
  10.   func main() {
  11.   reg, err := regexp.Compile("^132\\d{8}$")
  12.   fmt.Println(err, reg)
  13.   // 匹配 Match
  14.   fmt.Println(reg.MatchString("132xxx"))
  15.   fmt.Println(reg.MatchString("13212312312"))
  16.   // 替换 Replace 132????????
  17.   reg, err = regexp.Compile("132\\d{8}")
  18.   fmt.Println(reg.ReplaceAllString("我的电话是132xxx请记录下", "132????????"))
  19.   fmt.Println(reg.ReplaceAllString("我的电话是13212312312请记录下", "132????????"))
  20.   // 查找 Find
  21.   fmt.Println(reg.FindAllString("我的电话是13212312312,13212312313,15812312313", -1))
  22.   // 分割
  23.   reg, err = regexp.Compile("[:;\\t,]")
  24.   fmt.Println(reg.Split("13212312312,13212312313,15812312313:xxx;zzzz\tyyyyy", -1))
  25.   }
  1.   PS D:\Workspace\Go\src\projects\todolist> go run regexp.go
  2.   <nil> ^132\d{8}$
  3.   false
  4.   true
  5.   我的电话是132xxx请记录下
  6.   我的电话是132????????请记录下
  7.   [13212312312 13212312313]
  8.   [13212312312 13212312313 15812312313 xxx zzzz yyyyy]

longest.go

  1.   package main
  2.    
  3.   import (
  4.   "fmt"
  5.   "regexp"
  6.    
  7.   _ "github.com/go-sql-driver/mysql"
  8.   )
  9.    
  10.   func main() {
  11.   reg, _ := regexp.Compile("[ab0-9]+")
  12.   fmt.Println(reg.FindAllString("0-a23-b3456", -1))
  13.   // 定义非贪婪模式
  14.   reg, _ = regexp.Compile("(?U)[ab0-9]+")
  15.   fmt.Println(reg.FindAllString("0-a23-b3456", -1))
  16.   // 将非贪婪模式转换为贪婪模式
  17.   reg.Longest()
  18.   fmt.Println(reg.FindAllString("0-a23-b3456", -1))
  19.   }
  1.   PS D:\Workspace\Go\src\projects\todolist> go run longest.go
  2.   [0 a23 b3456]
  3.   [0 a 2 3 b 3 4 5 6]
  4.   [0 a23 b3456]

Web爬虫

Goquery

godocscaper.go

  1.   package main
  2.    
  3.   import (
  4.   "fmt"
  5.   "log"
  6.    
  7.   "github.com/PuerkitoBio/goquery"
  8.   )
  9.    
  10.   func main() {
  11.   q := "goquery"
  12.   url := "https://godoc.org/?q=" + q
  13.   // 发起http请求获取响应并创建Document结构体指针
  14.   document, err := goquery.NewDocument(url)
  15.   if err != nil {
  16.   log.Fatal(err)
  17.   }
  18.   // 在docuemnt中通过选择器去查找元素
  19.   // <tagname>
  20.   // 标签选择器
  21.   // 获取所有的a标签
  22.   selection := document.Find("a")
  23.   selection.Each(func(index int, tag *goquery.Selection) {
  24.   href, exists := tag.Attr("href")
  25.   // tag.Html()
  26.   fmt.Println(tag.Text(), href, exists)
  27.   })
  28.   fmt.Println("==============class==============")
  29.   // class选择器
  30.   // .className
  31.   // table
  32.   // 在table下获取所有的超链接
  33.   document.Find(".table-condensed").Find("a").Each(func(index int, tag *goquery.Selection) {
  34.   href, exists := tag.Attr("href")
  35.   // tag.Html()
  36.    
  37.   fmt.Println(tag.Text(), href, exists)
  38.   })
  39.   // id选择器
  40.   // #id
  41.   fmt.Println(document.Find("#x-search").Attr("class"))
  42.   fmt.Println(document.Find("#x-search").Html())
  43.   fmt.Println(document.Find("#x-search").Text())
  44.    
  45.   // 符合选择器
  46.   // tag + class
  47.   // <div></div><div class="nav"></div><span class="nav"></span>
  48.   // tag.class
  49.    
  50.   // 子孙选择器
  51.   // selector1 selector2 selector3 ...
  52.   fmt.Println("=========子孙选择器============")
  53.   document.Find(".table-condensed a").Each(func(index int, tag *goquery.Selection) {
  54.   href, exists := tag.Attr("href")
  55.   // tag.Html()
  56.    
  57.   fmt.Println(tag.Text(), href, exists)
  58.   })
  59.    
  60.   // 子选择器
  61.   // selector1 > selector2
  62.   // document.Find(selector1).ChildrenFiltered(selector2)
  63.   }

RPC

rpcserver

rpcclient

HTML结构

模板技术

  1.   package main
  2.    
  3.   import (
  4.   "fmt"
  5.   htmlTemplate "html/template"
  6.   "os"
  7.   "text/template"
  8.   )
  9.    
  10.   func main() {
  11.   // 显示数据
  12.   tplText := "我叫 {{ . }}"
  13.   tpl, err := template.New("tpl").Parse(tplText)
  14.   fmt.Println(err)
  15.   tpl.Execute(os.Stdout, `<img src="xxxx" />`)
  16.   fmt.Println()
  17.    
  18.   htmlTpl, err := htmlTemplate.New("tpl").Parse(tplText)
  19.   htmlTpl.Execute(os.Stdout, `<img src="xxxx" />`)
  20.   }
  1.   PS D:\Workspace\Go\src\projects\template> go run main.go
  2.   <nil>
  3.   我叫 <img src="xxxx" />
  4.   我叫 &lt;img src=&#34;xxxx&#34; /&gt;

Go语言操作Mysql数据库

Mysql的基本概念和操作方法

数据库基础

库、表、SQL

Mysql操作

  1.   1. 安装
  2.    
  3.   2. 创建新用户
  4.   create user golang identified by "1234";
  5.   grant all privileges on database.table to name@addr identified by password;
  6.   addr %
  7.   database.table *.* database.*
  8.    
  9.   grant all privileges on *.* to golang @'%' identified by "1234";
  10.    
  11.   flush privileges;
  12.   root/1234 禁止远程访问root用户
  13.    
  14.   3. 库
  15.   database
  16.    
  17.   创建:
  18.   create database name default charset utf8mb4;
  19.   查询:
  20.   show databases;
  21.   查看:
  22.   show create database name;
  23.   删除:
  24.   drop database name;
  25.    
  26.    
  27.   4. 表
  28.   use database;
  29.   创建
  30.   create table name (
  31.   colname coltype 修饰,
  32.    
  33.   index indexname (colname, colname1, colname2)
  34.   ) engine=innodb default charset=utf8mb4;
  35.    
  36.   colname: 列名 小写英文字母,数字, _组成
  37.   coltype: 数值类型
  38.   int
  39.   bigint
  40.   float
  41.   double
  42.   decimal(m, n)
  43.   字符串类型
  44.   varchar(n)
  45.   char(n)
  46.   时间类型
  47.   data
  48.   datetime
  49.   time
  50.   文本类型
  51.   text 64K
  52.   mediumtext 16M
  53.   longtext 4G
  54.   二进制类型
  55.   blob
  56.   longblob
  57.   json/array
  58.   ...
  59.   修饰:
  60.   主键: primary key
  61.   唯一: unique
  62.   自动增长: auto_increment
  63.   默认值: default 0, default ''
  64.   是否允许为null, 不允许为NULL, NOT NULL
  65.   注释: COMMENT ''
  66.    
  67.   索引:
  68.   index
  69.    
  70.   create table task(
  71.   id bigint primary key auto_increment,
  72.   name varchar(64) not null default '' comment '任务名称',
  73.   status int not null default 0 comment '状态, 0: 新建,1: 正在执行,2: 停止, 3: 完成',
  74.   start_time datetime comment '开始时间',
  75.   complete_time datetime comment '完成时间',
  76.   deadline_time datetime not null comment '截至时间',
  77.   index idx_name (name),
  78.   index idx_deadline_time(deadline_time)
  79.   ) engine=innodb default charset utf8mb4 auto_increment 1000;
  80.   查看
  81.   desc name;
  82.   show create table name;
  83.   查询
  84.   show tables;
  85.    
  86.   删除表:
  87.   drop table name;
  88.    
  89.   修改表
  90.   alter table name 动作;
  91.    
  92.   只允许添加列:
  93.   alter table name add column colname coltype 修饰;
  94.   删除列:
  95.   alter table name drop column colname;
  96.   修改列:
  97.   alter table name modify column colname coltype 修饰;
  98.    
  99.   5. 索引
  100.   create index name on table (column, column2, ...);
  101.   drop index name on table;
  102.    
  103.   create unique index name on table (column, column2, ...);
  104.    
  105.   6. 转义 ``
  106.   7. 表数据操作
  107.   增
  108.   insert into `table`(`c1`, `c2`, `c3`, `c4`) values(v1, v2, v3, v4);
  109.   insert into `table`(`c1`, `c2`, `c3`, `c4`) values
  110.   (v11, v12, v13, v14),
  111.   (v21, v22, v23, v24),
  112.   (v41, v42, v43, v44);
  113.   查
  114.   select * from table;
  115.   select c1, c2 from table;
  116.   select * from table where colname condition value;
  117.    
  118.   condition:
  119.   =, !=, >, <, >=, <=
  120.   like 模糊匹配
  121.   开头: like value%
  122.   结尾: like %value
  123.   包含: like %value%
  124.    
  125.   % 任务多个
  126.   __ 一个
  127.   like '%/%%' escape '/'
  128.   in (v1, v2) colname = v1 或者 colname = v2
  129.   colname between v1 and v2 => colname >= v1 and colname <= v2
  130.    
  131.   逻辑关系
  132.   与
  133.   and
  134.   或
  135.   or
  136.   colname = v1 or colname = v2
  137.   非
  138.   not
  139.   c1 = v1 and (c2 = v2 or c3 = v3)
  140.    
  141.   删
  142.   delete from table;
  143.   delete from table where 条件;
  144.   truncate table name;
  145.   改
  146.   update table
  147.   set colname=v1, col2=v2, col3=v3;
  148.    
  149.   update table
  150.   set colname=v1, col2=v2, col3=v3
  151.   where 条件;
  152.    
  153.   sql:
  154.   用户,权限,运维 操作:
  155.   库,表 操作: truncate table name; 重建
  156.   表数据 操作:
  157.    
  158.   8: 数量
  159.   count(*)
  160.   count(id)
  161.    
  162.   9. as 别名
  163.    
  164.   10. 查询
  165.   排序
  166.   order by colname [asc|desc], col2 [asc|desc]
  167.   分页
  168.   展示多少条数据 每页的数据量
  169.   展示第几页 页面
  170.   limit 限制查询数量
  171.   offset 设置偏移
  172.    
  173.   每页展示5条 limit 5
  174.   第一页 offset 0
  175.   第二页 offset 5 (pageNum - 1) * pageSize
  176.   分组
  177.   IP time url status_code
  178.   ip出现的次数
  179.   status_code出现的次数
  180.   url, status_code出现的次数
  181.   ip url status_code出现的次数
  182.   group by
  183.   select [] from table group by colname,colname2 [having 过滤条件;]
  184.    
  185.   select 元素必须是 指定分组的列名或者聚合类结果
  186.   count(*)
  187.   求和
  188.   最小值
  189.   最大值
  190.   平均值
  191.    
  192.    
  193.    
  194.   insert into task(name, content, deadline_time) values
  195.   ('1', '1', '2020-06-06'),
  196.   ('2', '1', '2020-06-05'),
  197.   ('3', '1', '2020-06-04'),
  198.   ('4', '1', '2020-06-02'),
  199.   ('5', '1', '2020-06-02'),
  200.   ('6', '1', '2020-06-02'),
  201.   ('7', '1', '2020-06-03');
  202.    
  203.    
  204.   create table accesslog(
  205.   id bigint primary key auto_increment,
  206.   logtime datetime not null comment '访问时间',
  207.   ip varchar(128) not null default '' comment '访问来源',
  208.   url varchar(4096) not null default '' comment '访问地址',
  209.   status int not null default 0 comment '状态码'
  210.   ) engine=innodb default charset utf8mb4;
  211.    
  212.    
  213.   insert into accesslog(logtime, ip, url, status) values
  214.   ('2020-06-06 01:01:01', '1.1.1.1', '/index', 200),
  215.   ('2020-06-05 01:01:02', '1.1.1.1', '/home', 302),
  216.   ('2020-06-07 01:01:02', '1.1.1.1', '/back.zip', 404),
  217.   ('2020-06-06 01:01:04', '1.1.1.1', '/ip.exe', 404),
  218.   ('2020-06-05 01:01:04', '1.1.1.2', '/ip.exe', 404),
  219.   ('2020-06-06 01:01:04', '1.1.1.2', '/ip.exe', 404),
  220.   ('2020-06-05 01:01:04', '1.1.1.2', '/ip.exe', 404),
  221.   ('2020-06-08 01:01:04', '1.1.1.3', '/home', 200);
  222.    
  223.   每天的访问数量
  224.   datetime => date '年-月-日'
  225.   select date_format(logtime, '%Y-%m-%d') as log_day, count(*) as cnt from accesslog
  226.   group by log_day;
  227.    
  228.    
  229.   ip出现的次数
  230.   select ip, count(*) from accesslog group by ip;
  231.   status_code出现的次数
  232.   select status, count(*) from accesslog group by status;
  233.   url, status_code出现的次数
  234.   select url, status, count(*) from accesslog group by url, status
  235.   ip url status_code出现的次数
  236.   select ip, url, status, count(*) from accesslog group by ip, url, status;
  237.    
  238.    
  239.    
  240.    
  241.   create table score(
  242.   id bigint primary key auto_increment,
  243.   day date not null comment '日期',
  244.   name varchar(32) not null default '' comment '姓名',
  245.   score float not null default 0 comment '分数'
  246.   )engine=innodb default charset utf8mb4;
  247.    
  248.   insert into score(day, name, score) values
  249.   ('2020-06-01', '烽火', 8),
  250.   ('2020-06-01', '魏超', 6),
  251.   ('2020-06-01', '阿宁', 7),
  252.   ('2020-06-02', '烽火', 5),
  253.   ('2020-06-02', '魏超', 5),
  254.   ('2020-06-02', '阿宁', 7),
  255.   ('2020-06-03', '烽火', 7),
  256.   ('2020-06-03', '魏超', 10),
  257.   ('2020-06-03', '阿宁', 9);
  258.    
  259.   统计每个人的总分, 最高分, 最低分,平均分
  260.   求和 sum
  261.   最小值 min
  262.   最大值 max
  263.   平均值 avg
  264.    
  265.   select name, sum(score),max(score),min(score), avg(score) from score group by name;
  266.   联查
  267.   多张表进行查询数据
  268.   join
  269.   left join on
  270.   inner join on
  271.   right join on
  272.    
  273.    
  274.   create table user(
  275.   id bigint primary key auto_increment,
  276.   name varchar(32) not null default '',
  277.   status int not null default 0 comment '0:在职, 1:离职'
  278.   ) engine=innodb default charset utf8mb4;
  279.    
  280.    
  281.   alter table task add column user bigint;
  282.    
  283.   insert into user(name, status) values
  284.   ('詹林', 0),
  285.   ('阿宁', 0),
  286.   ('cc', 1);
  287.    
  288.   insert into task(name, content, deadline_time, user) values
  289.   ('完成web todolist', '', now(), 1),
  290.   ('跑10圈', '', now(), 1),
  291.   ('洗衣服', '', now(), 1),
  292.   ('完成web todolist', '', now(), 2);
  293.    
  294.    
  295.   每个人(名字)未完成的任务
  296.    
  297.   select user.name, task.name from task left join user on task.user=user.id where task.status!=3;
  298.    
  299.   select user.name, task.name from task right join user on task.user=user.id where task.status!=3;
  300.    
  301.   insert into task(name, content, deadline_time, user) values
  302.   ('不存在用户的任务', '', now(), 5);
  303.    
  304.   11. 内置函数(调用)
  305.   now()
  306.   md5()
  307.   date_format(time, layout)
  308.    
  309.   12. 扩展
  310.   pg => 表继承
  311.   task
  312.   date
  313.   task_2020_05
  314.   task_2020_06
  315.    
  316.   insert int task
  317.   select * from task
  318.    
  319.   过程
  320.    
  321.    
  322.   13.
  323.   用户,权限,运维 操作: 执行
  324.   库,表 操作: 执行, 读
  325.   表数据 操作: 增,删,改 => 执行
  326.   查 => 读
  327.    
  328.   执行
  329.   读
  330.    
  331.    
  332.   编辑
  333.   1. 点击编辑按钮 id => 内容显示
  334.   2. 内容修改 id => 提交按钮 => 数据验证 => 更新数据
  335.   input type="hidden" value="{{ task.ID }}"

Go语言的常用包和使用方式

testdb\main.go

  1.   package main
  2.    
  3.   import (
  4.   "database/sql"
  5.   "fmt"
  6.   )
  7.    
  8.   // 导入beego包
  9.    
  10.   func main() {
  11.   // user:password@tcp(host:port)/database?charset=utf8mb4&loc=PRC&parseTime=true
  12.   dsn := "root:1234@tcp(192.168.204.130:3306)/todolist?charset=utf8mb4&loc=PRC&parseTime=true" // 字符串的格式由对应的驱动进行定义
  13.   db, err := sql.Open("mysql", dsn)
  14.   fmt.Println(db, err)
  15.   fmt.Println(db.Ping())
  16.    
  17.   // 执行
  18.   // sql => go 字符串
  19.   fmt.Println(db.Exec(`
  20.   create table if not exists testwu(
  21.   id bigint primary key auto_increment,
  22.   name varchar(32) not null default '' comment 'testwu名字'
  23.   ) engine=innodb default charset utf8mb4;
  24.   `))
  25.    
  26.   sql := `update task set status = ?`
  27.    
  28.   result, err := db.Exec(sql, 3)
  29.   fmt.Println(sql, err)
  30.   fmt.Println(result.RowsAffected())
  31.    
  32.   tid := "2 or 1=1"
  33.   result, _ = db.Exec(`update task set status = 2 where id=?`, tid)
  34.   fmt.Println(result.RowsAffected())
  35.    
  36.   result, _ = db.Exec(`delete from task where id=?`, 16)
  37.   fmt.Println(result.RowsAffected())
  38.    
  39.   tname := "买个电视x"
  40.   content := ""
  41.   deadline := 2022 - 10 - 10
  42.    
  43.   result, err = db.Exec(`insert into task(name, content, deadline_time) value(?, ?, ?)`, tname, content, deadline)
  44.   fmt.Println(err)
  45.   fmt.Println(result.LastInsertId())
  46.   fmt.Println(result.RowsAffected())
  47.   // 读
  48.   rows, err := db.Query("select id, name from task where id > ? limit 1", 18)
  49.   var (
  50.   id int
  51.   name string
  52.   )
  53.   if rows.Next() {
  54.   rows.Scan(&id, &name)
  55.   fmt.Println(id, name)
  56.   }
  57.    
  58.   // sql语句不能占位 展示变量
  59.   row := db.QueryRow("select id, name from task where id>? order by id desc", 10)
  60.   err = row.Scan(&id, &name)
  61.   fmt.Println(err, id, name)
  62.    
  63.   }

tx\main.go

  1.   package main
  2.    
  3.   import (
  4.   "database/sql"
  5.   "fmt"
  6.    
  7.   _ "github.com/go-sql-driver/mysql"
  8.   )
  9.    
  10.   // id 增加 money
  11.   func changeMoney(tx *sql.Tx, id int, money float64) error {
  12.   if money < 0 {
  13.   // 检查
  14.   var accountMoney float64
  15.   err := tx.QueryRow("select money from account where id=?", id).Scan(&accountMoney)
  16.   if err != nil {
  17.   return err
  18.   }
  19.   if accountMoney < -money {
  20.   return fmt.Errorf("没有足够的金额")
  21.   }
  22.   }
  23.   _, err := tx.Exec("update account set money=money+? where id=?", money, id)
  24.   return err
  25.   }
  26.    
  27.   func main() {
  28.   // user:password@tcp(host:port)/database?charset=utf8mb4&loc=PRC&parseTime=true
  29.   dsn := "root:1234@tcp(192.168.204.130:3306)/todolist?charset=utf8mb4&loc=PRC&parseTime=true" // 字符串的格式由对应的驱动进行定义
  30.   /*
  31.   create table account(
  32.   id bigint primary key auto_increment,
  33.   name varchar(32) not null default '',
  34.   money decimal(10, 5) not null default 0
  35.   ) engine=innodb default charset utf8mb4;
  36.    
  37.   insert into account(name, money) values("wu", 1000);
  38.   insert into account(name, money) values("烽火", 1000);
  39.   */
  40.   db, _ := sql.Open("mysql", dsn)
  41.    
  42.   // 转账
  43.   var a, b = 1, 2
  44.   // a => b money
  45.   // a - money
  46.   // b + money
  47.   var money float64 = 100.0
  48.   // 同时成功同时失败
  49.   // 事务
  50.   tx, _ := db.Begin()
  51.    
  52.   err1 := changeMoney(tx, a, -money)
  53.   err2 := changeMoney(tx, b, money)
  54.    
  55.   fmt.Println(err1, err2)
  56.   if err1 == nil && err2 == nil {
  57.   // 提交事务
  58.   tx.Commit()
  59.   } else {
  60.   // 回滚
  61.   tx.Rollback()
  62.   }
  63.    
  64.   }

stmt\main.go

  1.   package main
  2.    
  3.   import (
  4.   "database/sql"
  5.   "fmt"
  6.   "time"
  7.    
  8.   _ "github.com/go-sql-driver/mysql"
  9.   )
  10.    
  11.   // id 增加 money
  12.   func changeMoney(tx *sql.Tx, id int, money float64) error {
  13.   if money < 0 {
  14.   // 检查
  15.   var accountMoney float64
  16.   err := tx.QueryRow("select money from account where id=?", id).Scan(&accountMoney)
  17.   if err != nil {
  18.   return err
  19.   }
  20.   if accountMoney < -money {
  21.   return fmt.Errorf("没有足够的金额")
  22.   }
  23.   }
  24.   _, err := tx.Exec("update account set money=money+? where id=?", money, id)
  25.   return err
  26.   }
  27.    
  28.   func main() {
  29.   // user:password@tcp(host:port)/database?charset=utf8mb4&loc=PRC&parseTime=true
  30.   dsn := "root:1234@tcp(192.168.204.130:3306)/todolist?charset=utf8mb4&loc=PRC&parseTime=true" // 字符串的格式由对应的驱动进行定义
  31.   db, _ := sql.Open("mysql", dsn)
  32.   start := time.Now()
  33.   stmt, _ := db.Prepare(`insert into account(name, money) values(?, ?)`)
  34.   for i := 0; i < 10000; i++ {
  35.   stmt.Exec(fmt.Sprintf("a_", i), 1000)
  36.   }
  37.   fmt.Println(time.Now().Sub(start))
  38.   }

go-demo/todolist at main · yunixiangfeng/go-demo · GitHub

todolist\main.go

  1.   package main
  2.    
  3.   import (
  4.   "database/sql"
  5.   "fmt"
  6.   "log"
  7.   "net/http"
  8.   "strings"
  9.   "text/template"
  10.   "time"
  11.   "unicode/utf8"
  12.    
  13.   _ "github.com/go-sql-driver/mysql"
  14.   )
  15.    
  16.   const (
  17.   dbDriver = "mysql"
  18.   dbUser = "root"
  19.   dbPassword = "1234"
  20.   dbName = "todolist"
  21.   dbHost = "192.168.204.130"
  22.   dbPort = 3306
  23.   )
  24.    
  25.   const (
  26.   listenAdd = ":8888"
  27.   )
  28.    
  29.   const (
  30.   sqlTasks = "select task.id, task.name, task.status, task.start_time, task.complete_time, task.deadline_time, user.name as user from task left join user on task.user=user.id"
  31.   sqlCreateTask = "insert into task(name, content, deadline_time) values(?, ?, ?)"
  32.   sqlDeleteTask = "delete from task where id = ?"
  33.   )
  34.    
  35.   const (
  36.   dateTimeLayout = "2006-01-02 15:04:05"
  37.   )
  38.    
  39.   var (
  40.   statusMap = map[int]string{
  41.   0: "新建",
  42.   1: "正在进行",
  43.   2: "暂停",
  44.   3: "完成",
  45.   }
  46.   )
  47.    
  48.   type Task struct {
  49.   ID int
  50.   Name string
  51.   Status int
  52.   StartTime *time.Time
  53.   CompleteTime *time.Time
  54.   DeadlineTime *time.Time
  55.   User *string
  56.   Content string
  57.   }
  58.    
  59.   func (task *Task) StatusText() string {
  60.   return statusMap[task.Status]
  61.   }
  62.    
  63.   type TaskForm struct {
  64.   ID int
  65.   Name string
  66.   Status int
  67.   DeadlineTime string
  68.   Content string
  69.   User int
  70.   }
  71.    
  72.   func main() {
  73.   dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=utf8mb4&parseTime=true&loc=PRC", dbUser, dbPassword, dbHost, dbPort, dbName)
  74.    
  75.   // 打开数据库连接池
  76.   db, err := sql.Open(dbDriver, dsn)
  77.   if err != nil {
  78.   log.Fatal(err)
  79.   }
  80.    
  81.   // 测试数据库连接
  82.   if err := db.Ping(); err != nil {
  83.   log.Fatal(err)
  84.   }
  85.    
  86.   // 显示任务列表
  87.   http.HandleFunc("/", func(response http.ResponseWriter, request *http.Request) {
  88.   tasks := make([]Task, 0, 20)
  89.   rows, err := db.Query(sqlTasks)
  90.   if err == nil {
  91.   for rows.Next() {
  92.   var task Task
  93.   err := rows.Scan(&task.ID, &task.Name, &task.Status, &task.StartTime, &task.CompleteTime, &task.DeadlineTime, &task.User)
  94.   if err == nil {
  95.   tasks = append(tasks, task)
  96.   } else {
  97.   fmt.Println(err)
  98.   }
  99.   }
  100.   }
  101.   funcs := template.FuncMap{
  102.   "datetime": func(t *time.Time) string {
  103.   if t == nil {
  104.   return "--"
  105.   }
  106.   return t.Format(dateTimeLayout)
  107.   },
  108.   "status": func(status int) string {
  109.   //status int => string
  110.   //if
  111.   //switch
  112.   return statusMap[status]
  113.   },
  114.   }
  115.   // 模板函数必须在解析模板之前进行设置
  116.   tmpl := template.Must(template.New("tpl").Funcs(funcs).ParseFiles("views/tasks.html"))
  117.   tmpl.ExecuteTemplate(response, "tasks.html", struct {
  118.   Tasks []Task
  119.   }{tasks})
  120.   })
  121.    
  122.   http.HandleFunc("/add/", func(response http.ResponseWriter, request *http.Request) {
  123.   var (
  124.   task TaskForm
  125.   errors = make(map[string]string)
  126.   )
  127.   if request.Method == http.MethodGet {
  128.   // 加载模板
  129.   } else if request.Method == http.MethodPost {
  130.   name := strings.TrimSpace(request.PostFormValue("name"))
  131.   content := strings.TrimSpace(request.PostFormValue("content"))
  132.   deadlineTime := strings.TrimSpace(request.PostFormValue("deadline_time"))
  133.   task = TaskForm{
  134.   Name: name,
  135.   Content: content,
  136.   DeadlineTime: deadlineTime,
  137.   }
  138.   nameLength := utf8.RuneCountInString(task.Name)
  139.   if nameLength == 0 {
  140.   errors["name"] = "任务名不能空"
  141.   } else if nameLength > 32 {
  142.   errors["name"] = "任务名不能超过32个字符"
  143.   }
  144.    
  145.   contentLength := utf8.RuneCountInString(task.Content)
  146.   if contentLength > 512 {
  147.   errors["content"] = "任务描述不能超过512个字符"
  148.   }
  149.    
  150.   if _, err := time.Parse("2006-01-02", deadlineTime); err != nil {
  151.   errors["deadline_time"] = "任务期限不能为空"
  152.   }
  153.    
  154.   // 验证完成,无错误
  155.   if len(errors) == 0 {
  156.   db.Exec(sqlCreateTask, task.Name, task.Content, task.DeadlineTime)
  157.   http.Redirect(response, request, "/", http.StatusFound)
  158.   }
  159.    
  160.   }
  161.   tmpl := template.Must(template.ParseFiles("views/add_task.html"))
  162.   tmpl.ExecuteTemplate(response, "add_task.html", struct {
  163.   Task TaskForm
  164.   Errors map[string]string
  165.   }{task, errors})
  166.    
  167.   })
  168.    
  169.   http.HandleFunc("/delete/", func(response http.ResponseWriter, request *http.Request) {
  170.   id := request.FormValue("id")
  171.   db.Exec(sqlDeleteTask, id)
  172.   http.Redirect(response, request, "/", http.StatusFound)
  173.   })
  174.    
  175.   http.ListenAndServe(listenAdd, nil)
  176.   }

todolist\views\tasks.html

  1.   <!DOCTYPE html>
  2.   <html>
  3.   <head>
  4.   <meta charset="utf-8"/>
  5.   <title>任务列表</title>
  6.   </head>
  7.   <body>
  8.   <a href="/add/">新建</a>
  9.   <table>
  10.   <thead>
  11.   <tr>
  12.   <th>名称</th>
  13.   <th>负责人</th>
  14.   <th>状态</th>
  15.   <th>开始时间</th>
  16.   <th>完成时间</th>
  17.   <th>限期</th>
  18.   <th>操作</th>
  19.   </tr>
  20.   </thead>
  21.   <tbody>
  22.   {{ range .Tasks }}
  23.   <tr>
  24.   <td>{{ .Name }}</td>
  25.   <td>{{ .User }}</td>
  26.   <td>{{ .StatusText }}</td>
  27.   <td>{{ datetime .StartTime }}</td>
  28.   <td>{{ datetime .CompleteTime }}</td>
  29.   <td>{{ datetime .DeadlineTime }}</td>
  30.   <td>
  31.   <a href="/delete/?id={{ .ID }}">删除</a>
  32.   </td>
  33.   </tr>
  34.   {{ end }}
  35.   </tbody>
  36.   </table>
  37.   </body>
  38.   </html>

todolist\views\add_task.html

  1.   <!DOCTYPE html>
  2.   <html>
  3.   <head>
  4.   <meta charset="utf-8" />
  5.   <title>添加任务</title>
  6.   </head>
  7.   <body>
  8.   <form action="/add/" method="POST">
  9.   <label>名称: </label> <input type="text" name="name" value="{{ .Task.Name }}" />{{ .Errors.name }}<br />
  10.   <label>描述: </label> <textarea name="content">{{ .Task.Content }}{{ .Errors.content }}</textarea><br />
  11.   <label>期限: </label> <input type="date" name="deadline_time" value="{{ .Task.DeadlineTime }}"/>{{ .Errors.deadline_time }} <br/>
  12.   <input type="submit" value="提交" />
  13.   </form>
  14.   </body>
  15.   </html>

0817 day10

1. 注册过程
    a. 打开注册页面 / GET
    b. 填写信息 点击注册按钮 提交数据 /register/ POST

持久化使用文件

2. Todolist
    a. 显示任务列表 => /

        1. 洗衣服            x
        2. 看电视            x
        3. 看数             x

    b. 添加流程
        i. 添加超链接 => 添加页面
        ii. 填写数据 点击添加按钮 添加数据到持久化
        iii. 重定向到任务列表页面
    c. 修改流程
        i. 点击修改按钮 => 修改数据标识(ID)提交到服务器端 => 修改页面(原数据需要填充在表单中)
        ii. 修改数据 点击提交按钮  修改数据到持久化
        iii. 重定向到任务列表页面
    4. 删除流程
        i. 点击删除按钮 => 删除数据标识(ID)提交到服务器端
        ii. 删除数据,修改数据到持久化
        iii. 重定向到任务列表

id
name
user
progress
status

1. 模板 => 加载
2. 模板 + 数据 => html
    如何显示数据
    如何遍历数据
    如何用条件

0824 day11

1. 用户列表显示
    前 -> 后
    / => controller => model => view

    后->前
    model->controller->view->handle

    a. /users/ => Action => HandleFunc
    b. model => 文件中加载 => 返回
    c. views => users.html

2. 用户列表查询
    用户输入数据(input q) form
    form action=? method=?
    /users/ get q=xxx
    FormValue("q")
    users = GetUsers(q)


    /users/query post

    PostFormValue("q")

    GetUsers()
    for users
    users contains q

3. 用户登陆
    a. 打开登陆页面
        Get /user/login => Action => Execute(user/login.html)

    b. 登陆流程
        POSt /user/login

        方法一: 获取用户名/密码 => 验证 找输入用户名/密码都相等的用户
        [用]方法二: 通过用户名去查找用户 => 没找到 User
                    找到 => 判断密码是否正确(通过User方法来验证)

        认证成功
            => 跳到到任务列表
        认证失败
            => 返回到输入信息页面,并提示错误,及用户原输入信息

    发现用户没有登陆时跳转到登陆页面让进行登陆
    机制:跟踪用户状态
    session + cookie

    你银行办业务

    你(浏览器)                 银行(服务器)
    1. 第一次去银行              开户                     0
                                给你银行卡
    2. 第二次去银行带上卡           存1w                  1w
    3. 第3次去银行带上卡            取1k                  9k
    4. 没带银行卡                想要取钱(银行拒绝)


    cookie的存储: 在浏览器
    cookie的信息: 卡号

    浏览器                                  服务器
    1. 第一次请求                               开辟一定存储空间(编号=>session ID, 存储空间=>session)
                                               将session ID返回给客户端

                                                    response header
                                                    Set-Cookie: session=xxxxx
        浏览器接收到请求存储cookie信息

    2. 第二次请求   浏览器会读取cookie信息(session ID)并通过http请求提交给服务器      (登陆 成功 在存储空间User)
                                            获取Session ID 查找对应存储空间中的数据
    3. 以后请求中都会带cookie信息                   从存储空间中尝试获取User,如果没有获取到, 未登陆
                                                                         如果获取到,已登录


    技术:
        怎么生成Session ID => go.uuid

        存储内存/文件/数据库/redis

        怎么设置, 怎么取修改response header set-cookie
        获取cookie request

4. 退出登陆
    session销毁
    cookie销毁

5. 添加用户
     a. 打开添加页面
        Get /users/create/
     b. 提交数据
        Post /users/create/
        r.PostFormValue
        验证
            用户名长度 4-12
                不允许重复
            密码长度 6-30
            出生日期 1960 - 2019
        验证成功 添加用户并持久化
        验证失败,返回添加页面,并回显错误和输入信息

day12 

mvc

 

day13

表 => struct
列 => struct 属性
行数据 => struct 对象

数据操作 => struct 对象方法的调用/函数的调用

day17

beego.Get("/", function(c *context.Context) {

})


/users/delete/?id=1
/users/delete/1/

:name

/users/delete/:id:int/

type UserController struct {
    beego.Controller
}

beego.Router("/user/", &UserController{})

PUT /user/
GET /user/


Login
Error

Get /user/ => Login
Post /user/ => Login
其他的 /user/ => Error
PUT /user/ => Create
DELETE /user/ = > Delete

beego.Router("/user/", &UserController{}, "get,post:Login;put:Create;delete:Delete;*:Error")

beego.AutoRouter(&UserController{})

Login
Error
Create
Delete

/user/login => Login
/user/error => Error


login:
body: name, password

delete:/delete/?id=1


type LoginForm struct {
    Name string `form:"name"`
    Password string `form:"password"`
}


1. layouts 公共js/css
2. LayoutContent
    每个页面都自己的js/css
    LayoutSections

    LayoutStyles
    LayoutScripts

3. Database
    a. table => 页面 => DataTable生成分页页面数据(前端查询 js)
    b. ajax => 请求数据 => DataTable根据ajax返回数据生成分页页面数据(前端查询 js)
    c. 全后端 ajax

    jQuery.get
    jQuery.post
    url, {}, function(response) {}, "json"


    "code" : 200/400/403/500
    "text": "",
    "result": nil/[]/{}

创建
    dialog => 内容(index.html) 不发送请求
编辑
    a. dialog => 表单内容(index.html)
                数据 => 发送请求获取的 ajax => 填充到表单中
                对应关系的问题
    dialog => ajax 获取表单内容+数据 html => 放在dialog中
        jQuery(selector).load(url) ajax

day18

AKDxc4

< &lt;
> &gt;
" &quot;
' &#39;
& &amp;


outercondition = innercondition and

(name like '%xxx%' or desc like '%xxx%') and create_user = 1


total, totalFilter

管理员
    total  select count(*) from user

    totalFilter select count(*) from user where q=xxxx

普通用户
     total  select count(*) from user where create_user = xxxx

    totalFilter select count(*) from user where q=xxxx and create_user  = xxx


    先设置用户条件 求count total
    再设置查询条件 求count totalFilter


第二页 10 10


1. 排序,后端需要维护0 => name关系
    => 能不能前端 直接告诉后端用哪个列进行排序(列名)

2. 页面上有不能排序的列
    => datatable能不能针对某一列指定进行排序

3. key => search[value] order[0][dir]/order[0][column]
    自定定义
4. 参数传递了一堆 columns[7]

    => 能不能自定义提交发起ajax的参数

1. 修改datatable的布局 dom: lftip 定义一个放置button按钮div
    l: 显示分页数据
    f: 搜索
    t: 表格内容
    i: 搜索数量
    p: 翻页

    < f>
    <"className" >
    <"#id">

    <"row" <"col-2" l><"col-2" i><"col-8"p>>

    <div class="row">
        <div class="col-2"> l</div>
        <div class="col-2"> i</div>
        <div class="col-2"> p</div>
    </div>
2. datatable绘制完成后 使用jquery再button div中插入咱们的按钮
    div html方法

    <"row" <"col-5" l><"col-6" f><"#buttons.col-1">>tip

        <div class="row">
        <div class="col-5"> l</div>
        <div class="col-6"> f</div>
        <div class="col-1" id="buttons"></div>
    </div>

用户管理平台cmdb

第一版 go1.13.15+k8s1.18.8+beego v1.12.2+mysql+prometheus

用户管理模块 新建、查询、修改、删除用户功能,用户密码修改功能

用户管理

        登陆验证

        管理页加载

        用户数据加载

        增/删/改/锁定/解锁

云主机管理

主机资源监控

prometheus节点、任务、目标、告警功能,alartmanager告警通知,短信tencent_sms,邮件smtp

redis保存session

kubernetes管理deployment、service、ingress创建,查询,修改,删除功能。

go-demo/cmdb at main · yunixiangfeng/go-demo · GitHub

day12

自述

MVC:

M=>Model: 模型
V=>View: 视图
C=>Controller: 控制器

分层原则
客户端请求: http协议 => url, method, params

服务器处理客户端过程: url => handler => params => db => template => html
a. 定义处理器
    params
b. 处理器调用数据库对数据进行处理(增/删/改/查)
c. 处理器调用模板基础去渲染页面
d. 定义url处理器管理

客户端渲染: http渲染页面

day13

controller逻辑图

自述

登录成功后显示用户列表
url->用户列表页面展示
Controller => Model(获取用户数据) => View => Router


用户认证
记录用户状态? 记录在哪里?
HTTP无状态? 下一次请求

cookie session机制
状态记录 => session
    在什么时间记录(代码什么位置)?
    登录成功 记录状态 (session) sessionid
    setcookie sessionid
状态的跟踪 => (sessionid) => cookie


登录状态
    无sessionid
    有sessionid sessionid无对应session信息
    有sessionid sessionid无session登录状态

    未登录(无session登录标识)
        跳转到登录页面
    已登录 => 正常逻辑

    用户鉴权


beego
    开启: 配置 SessionOn=true/false
    存储位置: 内存,文件,数据库
            SessionProvider: file/mysql/redis
    存储的地址
            SessionProviderConfig
    cookie中存储sessionid的名字
            SessionName
    失效时间
        SessionGCMaxLifetime = 3600 s

    操作
        存储session
            controller: SetSession key value 可以是任意类型的
                        持久化的编码方式 gob 注册
        获取session
            controller: GetSession key => value interface{}
                        断言
        销毁session
            key1
            key2

            controller: DelSession(key)
            DestorySession()

1. session(登录检查)
    在任何需要登录以后才能访问的action执行之前都需要进行检查
2. 如果访问登录页面
    检查session已存在(用户已登录,就不在打开登录页面,直接跳转到首页)


1. 公共地方检查
    beego的执行过程


数据操作
存储: Table
数据 增/删/改/查

数据定义 Table => 列,类型 => 数据 => 增,删,改,查
面向对象 类 => 属性(属性名, 类型) => 实例 => 方法调用
ORM

day14

自述

静态资源下载在本地

static

/static/ => static
/static/a.js => static/a.js
/static/a/b.js => static/a/b.js

用户管理

// 任务管理

资产管理
机房管理
工单
告警管理
统计图标


1. 编辑
    a. 打开编辑
        GET id => 查找 => 渲染
    b. 提交
        POST id/xxx => 更新数据 => (成功)跳转到列表页面
                                  (失败)

day15

代码结构

 部署 

自述

 [x]1. 用户管理 => 修改自己密码

    a => 打开用户修改密码页面

        /*

        controller 参数 uid => 验证用户uid当前用户 => 是 => 获取用户信息显示 (用户名) => 加载视图

                                                    不是 =>

                        session => uid => loginuser

        */

        controller => 加载视图

        views/tpl

        rounter(url=>controller)

    b. => 提交数据

        旧密码 => 新密码(确认)

        Form

        parseForm

       检查旧密码

        新密码 和 确认密码是不是一致

        新旧不能一样

        密码 必须包含数字,大小写英文,特殊字符(.@!$#) 至少3中, 6

        update user set password="xxx" where id=uid

[x]2. CSRF

    网络攻击

    扩展请求伪造

    a. 配置

    开启CSRF防护

    配置Token => key

    过期时间

    b. 打开页面生成TOken

        从Controller生成 传递到页面

    c. 提交数据提交Token

        beego自动验证(POST,DELETE,PUT)

        csrf_token =>

[x]3. Flash

    处理成功后将消息存储 cookie

    想要显示时从存储中获取消息并显示 从cookie中读取/删掉

    页面使用后端模板

    从当前Controller某个URL跳转到另外一个URL

    存储

    flash := beego.NewFlash

    flash.Set(key, value)

    flash.Store(&c.Controller)

    // 获取

    flash := beego.ReadFromRequest(&c.Controller)

    // readFromRequest     c.Data[key] = value

    flash.Data

[x]4. 错误处理

[x]5. 验证

[x]6. 日志

[x]7. Layout&LayoutSection

[x]13. Cache

    缓存

8. 用户权限

    jd

        万志强 => user

        kk => user

        管理侧 => 添加商品

                  维护价格

                 用户管理

    角色 不同角色 不同功能

         相同角色 不同数据

    水平权限: 相同角色, 数据不共享, 数据的属性

    垂直权限: 不同角色 A => 1, 2, 3 A-> 4(权限错误,提权)

                      B => 2, 3, 4

    Todolist

    user 角色 role 1 => 管理员 2 =>普通用户

    修改密码

    Task管理

    用户管理

    管理员: 操作用户管理, 所有用户的Task管理

            UserController

                Prepare => 判断用户时非管理员 => 跳转到无权限页面

                            是管理员 => 继续访问

            TaskController

    普通用户: Task管理,只能对自己创建的任务进行管理

            Task => User属性

            TaskController

                Query => user == current.ID

                Add => current.ID => db

                Detail => id, user => data

                modify => id, id =data => data.user == current.ID

                delete => id => data, data.user == current.ID

    如何限制普通用户操作UserController

                    发起请求-》请求操作成功

    如果限制未登录用户操作UserController

        session => User 有 放行

                        无 跳转到登录页面

    role {

        1 : [controller1.Action1, controller2.Action2],

        2 : [controller1.Action1, controller1.Action2]

    }

    Authorization => session => user => role => actions

                    GetControllerAndAction

        在 actions => 有权限

        不在 => 无权限

9. 过滤器

[x]10. 部署

[x]11. HTTPS

[x]12. cobra

    beego orm --db --force --verbose

    main web

         db

         init

name {

    attr: value;

}

html->head

<style type="text/css">

</style>

<link href="css path" rel="stylesheet" type="text/css" />

User

type userService struct {

}

Add

Find/Query

Detail

Delete

UserService = new(userService)

A UserService.Add

B UserServiceInstance

day16

csrf

自述

c.Data["token_input"] = template.HTML(`<input type="text" value="xxx" name="xxxx" />`)


{{ token_input }} // <input xxxx/> []

beego 防止xss攻击 <input/> &lt;


菜单(显示):
    用户管理
    任务管理

管理员
    用户管理
    任务管理

普通用户
    任务管理

user => role
role => template => if => func

hasPerssion(.user, "key")


menus := []Module{
    Moudule("user", "action", "用户管理", [contaoller.action]),
    Moudule("task", "action", "任务管理")
},

垂直权限 : rbac
水平权限 : 基于属性的

role =>
    管理员 => user, task
    普通用户 => task


    Prepare()
    loginUser.Role => Modules => [Controller.action]

    c.GetControllerAndAction() in [Controller.Action]

    else
        无权限
        c.Redirect()
        c.Abort("notpermission")

day19

1. Alartmanager告警通知
    a. 短信 腾讯
    b. 邮件 smtp

    告警通知以分组为单位
    告警处理以告警为单位

2. Redis
    a. redis基本操作
    b. redigo使用
    c. beego session redis
    d. beego cache redis
3. syncd 代码部署
    a. 介绍&功能演示
    b. gin介绍
    c. 代码走读
        认证&授权 jwt
        编译过程
        部署过程

    目的:
        a. 学习别人的开发思路
        b. beego => gin
        c. 学习看开源代码

同步方式
    需要等待执行完成后返回
异步方式
    不需要等待执行结束直接返回

    队列
        db
        rabbitmq/kafka
        redis
        file

redis:
    key value 基于内存的存储

    1. 缓存
    2. 分布式功能, 持久化 rdp, aof 存储
    3. 分布式锁, 原子操作 setnx
        zookeeper/etcd
    4. 消息队列, aof
        rabbitmq/kafka/activmq

    key value => map key value=>type

    type:
        key:
            组成 英文字母(大小写), 数字, _
            开头 英文字母
            功能层级名称
                cmdb:xxx:

            cmdb:test:
        常用的数据类型
        key
            判断key是否存储
                keys *
                exstis key
            判断key类型
                type key
            设置过期时间/ 查看过期时间
                ttl/expire
            删除key
                del
        string
            设置/更新:
                set key value
            获取
                get key
            加1(n)/减1(n)
                incr/decr
                incrby/decrby
            追加
                append

            缓存:
                1. 先从缓存中获取
                    获取到返回
                2. 查询/计算
                    放入缓存 设置失效时间
                    返回
        list []interface{}
            左/右

            放入元素PUSH
                 LPUSH/RPUSH

            拿出元素POP
                LPOP/RPOP
                阻塞
            获取元素数量
                llen

            查看所有元素
                0 -1
                lrange key start end
            2 1

            队列
                先入先出
                    LPUSH RPOP
                    RPUSH LPOP

                阻塞
                    RPOP => 无元素返回nil

            for {
                value := rpop => value
                if value == nil {
                    time.Sleep(1s)
                    continue
                }
                op(value)
            }


            for {
                value := brpop => key value
                if value == nil {
                    continue
                }
                op(value)
            }
        hash map
            key hash
                k => v

        set 集合 元素不重复
            sadd
            srem
            sinmember
            smembers

            sinter
            sdiff
            sunion
        zset 有序集合
            zadd

            优先级任务
            权重 任务ID

            zrange key 0 0
            zrevrange key 0 0

            zrem member


            task:id hash

        地理位置
        bitmap
        ...

    默认无认证
        require

    go 操作

开发流程

创建项目结构

修改配置文件

编写启动文件

登陆

        用户/Token模型定义

        登陆页面加载

        提交用户名/密码登陆验证

        验证结果处理

用户管理

        登陆验证

        管理页加载

        用户数据加载

        增/删/改/锁定/解锁

        Token查看/生成

gocmdb

第二版 

  1.   go install github.com/GoAdminGroup/adm@latest
  2.    
  3.   mkdir gocmdb/server && gocmdb/server
  4.    
  5.   adm init -l cn
  6.    
  7.   go mod init github.com/yunixiangfeng/gocmdb/server
  8.    
  9.   go mod tidy

云主机管理平台

© All Rights Reserved. GoAdmin

  1.   <div class="row" style="padding-top: 60px; clear: both;">
  2.   <div class="col-md-12 text-center">
  3.   <p>
  4.   <small>&copy; All Rights Reserved. GoAdmin</small>
  5.   </p>
  6.   </div>
  7.   </div>

滑动验证码_PC

  1.   <script src="https://ssl.captcha.qq.com/TCaptcha.js"></script>
  2.   <script>
  3.    
  4.   let captcha = new TencentCaptcha("2078016841", function (res) {
  5.   console.log(res);
  6.    
  7.    
  8.   if (res.ret === 0) {
  9.   $.ajax({
  10.   dataType: 'json',
  11.   type: 'POST',
  12.   url: '\/admin/signin',
  13.   async: 'true',
  14.   data: {
  15.   'username': $("#username").val(),
  16.   'password': $("#password").val(),
  17.   'token': res.ticket
  18.   },
  19.   success: function (data) {
  20.   location.href = data.data.url
  21.   },
  22.   error: function (data) {
  23.   alert('登录失败');
  24.   }
  25.   });
  26.   } else {
  27.   alert("验证失败")
  28.   }
  29.   }, {});
  30.    
  31.   function submitData() {
  32.   captcha.show()
  33.   }
  34.   </script>

主机资源监控与实战

 

syncd 代码部署

    a. 介绍&功能演示
    b. gin介绍
    c. 代码走读
        认证&授权 jwt
        编译过程
        部署过程

容器云k8s与二次开发

day20-0829

docker基本使用

k8s基本概念和环境搭建

k8s基本操作

k8s dashboard

k8s client创建资源

k8s client获取资源

k8s client修改资源和删除资源

k8s web管理

k8s ingress

1. k8s搭建

kubeadm

    kubeadm init \
    --apiserver-advertise-address 10.0.0.10 \
    --image-repository registry.aliyuncs.com/google_containers \
    --kubernetes-version v1.18.6 \
    --service-cidr 10.1.0.0/16 \
    --pod-network-cidr 10.244.0.0/16

    kubectl apply -f https://raw.githubusercontent.com/coreos/flannel/master/Documentation/kube-flannel.yml


    discovery-token-ca-cert-hash: https://kubernetes.io/zh/docs/reference/setup-tools/kubeadm/kubeadm-join/
    /api/v1/namespaces/kubernetes-dashboard/services/https:kubernetes-dashboard:/proxy/#/login
2. k8s client介绍
3. k8s管理
    deployment
    service
    ingress
4. docker

API与SDK的介绍与使用

配置/证书下载

- https://pan.baidu.com/s/1vfcvOR8g4Y4Hf4v34M2OeA&shfl=sharepset

kubeadm部署

- 准备环境

安装docker

 k8s

 kubeadm安装

dashboard安装

二进制部署 

kubectl命令 

资源配置文件YAML 

docker

Docker是一个用于开发,交付和运行应用程序的开放平台

安装

架构

技术

镜像

容器

容器时一个镜像的容器实例

挂载

网络

dockerfile 

docker-compose 

 

自建私有镜像仓库

使用Go语言对k8s资源对象操作与控制

k8s client获取资源

D:\codes\k8sclient\etc\kube.conf

  1.   apiVersion: v1
  2.   clusters:
  3.   - cluster:
  4.   certificate-authority-data: LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUN5RENDQWJDZ0F3SUJBZ0lCQURBTkJna3Foa2lHOXcwQkFRc0ZBREFWTVJNd0VRWURWUVFERXdwcmRXSmwKY201bGRHVnpNQjRYRFRJd01EZ3lPVEEwTURBeE9Wb1hEVE13TURneU56QTBNREF4T1Zvd0ZURVRNQkVHQTFVRQpBeE1LYTNWaVpYSnVaWFJsY3pDQ0FTSXdEUVlKS29aSWh2Y05BUUVCQlFBRGdnRVBBRENDQVFvQ2dnRUJBTUNQCjdQdmdidFp5b3FDRVh1dVMrZFZTNThaUlZXTVN4VkRmRkFXR1F2cEVLb2tuNGZRMWNUVmcvaGt1L0xwTE9NeEsKWll2TWRETFRnVWFjZGlJOTlFM216eWNKZ2pKbVN0VWJMZWlqbEFaNDZzYVEvZHJlaUxIYSt0R2Q3bVpCcmZXMgoxWG5jSUYyMm5Oa0pMaS9JNloyalZqYkMvaytwS2FoSDhPeU9HU2kwdWVUZ2lhWjRMeElwT1k5U2dONmQvREdrCkVWSmRXa1hkRTRZV1B4MHpQcXFIUW9XN1VVdFlzcnBTUXR0NTE2bkNEdTlacmwvc2tlb2dRbDdOTWVUSkR3RWEKZTI5NVFsY1g5RlVBTHh2eVBsbmpLWjRTK3lueVdXR1VmTTBzOGJ3bWIycWdTV2hqSHdRalY2ZVJiODdyYVdpVQpOZW91dG9najJzeEFxL3FUdEtrQ0F3RUFBYU1qTUNFd0RnWURWUjBQQVFIL0JBUURBZ0trTUE4R0ExVWRFd0VCCi93UUZNQU1CQWY4d0RRWUpLb1pJaHZjTkFRRUxCUUFEZ2dFQkFEdHROK1hydUZwbkFNdmxZRStFb3BVL0J0SUMKM0VSMFZacG5idk9yNm16ZDM4UHNFS24zWGlQcGFKeUpMRENUeHcyT3c5RXRIRHV0QlFlQStHNkhqRlJBUEZSZApSZC9hdXkvUkwyK3YycU1XNEt0YUxvWDdXaXhiQ1JBNEs2dk83UVhGeCtab1RETDR0K3VjL2ZlanQ4dkdyc1V2CjYzaXB1MHp5U3NWZGIwbmJlRlpTa3VGOHM2eUZPVlIxdlhxa0FjVGQrek9lcUs0MkVzRlRBNVFaZ080Nm5UclAKcHdiK1lZVnlodTZsWUc4c2tDZ0NjSWdnMW41bC9FNXpiQUo1YzVwdjN3S200dGZEVVJON0xmbVVPa01iUlAwQQprakcwOHNUOGNmOEJEdTNiZWN1b3FQNW9ZVTRVcUFGZUFETEhlSFFNdklpRXVQdlBDbU5WNzZiVFRiMD0KLS0tLS1FTkQgQ0VSVElGSUNBVEUtLS0tLQo=
  5.   server: https://192.168.204.130:6443
  6.   name: kubernetes
  7.   contexts:
  8.   - context:
  9.   cluster: kubernetes
  10.   user: kubernetes-admin
  11.   name: kubernetes-admin@kubernetes
  12.   current-context: kubernetes-admin@kubernetes
  13.   kind: Config
  14.   preferences: {}
  15.   users:
  16.   - name: kubernetes-admin
  17.   user:
  18.   client-certificate-data: LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUM4akNDQWRxZ0F3SUJBZ0lJWkRtRHo3ZVkzWHN3RFFZSktvWklodmNOQVFFTEJRQXdGVEVUTUJFR0ExVUUKQXhNS2EzVmlaWEp1WlhSbGN6QWVGdzB5TURBNE1qa3dOREF3TVRsYUZ3MHlNVEE0TWprd05EQXdNakZhTURReApGekFWQmdOVkJBb1REbk41YzNSbGJUcHRZWE4wWlhKek1Sa3dGd1lEVlFRREV4QnJkV0psY201bGRHVnpMV0ZrCmJXbHVNSUlCSWpBTkJna3Foa2lHOXcwQkFRRUZBQU9DQVE4QU1JSUJDZ0tDQVFFQXpwUmdKMnZUdnVIeFVNTDMKbENBSVMxSzB5eitaLzU3SW1uZnFkY3NtU2RPK2t0UjJRQlRrUzJSNTNlWGp1a1U1NTNhUDl5M3BWWHE4bk9oSwpOYU9yMnVLWCt6MXVraTRWaHdnRGdHT0ZnYjl5VVMzSnhmc3V4V2NtY2NSWGtHK3pCVmJHTjRSUTdiTk5LdE5iCjN2VSszNHV3UEozQWJ3Z3JZQ2poUDFWcDBkZWF2VFlBMThMUHJnYVFkUG1IclE0WEtwdFJWWld6cEdmK2RKR0IKZklBLzVSR2VBMmRBK1R0SkVDSUhXakhDdDBISkhxK3h3YzhRN09YUmduaFRUTXF4dHNCcC9hUjd6VnRzYUliTQpaR1RhbzlQYVk3UWp1WnRGU0lpZFhHaTZjeVdkSUxCVWpMemdTY2Z2RTJ0QnR3d1UvVTJYSk9wWmhldklWMVAyCng2V1U5UUlEQVFBQm95Y3dKVEFPQmdOVkhROEJBZjhFQkFNQ0JhQXdFd1lEVlIwbEJBd3dDZ1lJS3dZQkJRVUgKQXdJd0RRWUpLb1pJaHZjTkFRRUxCUUFEZ2dFQkFLVVA5RFZXZ2oxZ3hmSEV5S0ZoMlZkc1B1MjI3NlFoRW80RQpvTTBOSngzQnZ2d1N0M3pTMXhyVFJqOGsraG8zS1dJSEVXWTRjK1M1N25lNU1Gd3BaSTZQT2xqM2Rla0FkOXZhCnIwS1plSnZGRTN4WCt0YzhhR1ZEZ3NLbkozWDhBQW4wUXhubFpjUDhHUjZieC9uaGpaeDNMWUNZVjFGTytyOXMKTkp3UjR6MDhiUUpFQ0x3RSswT2R6eUdYb1c1SXRKalRSMGE2Zm5ReGVSeUJtMm11ZHdBeXdDVW1lYm1EcVNCQgpOejZ4M2FVcXJyRDZ3cGZVa25acGZkT04rRVR5WjVTOXhSQzl0RE4vOVhMQ2dHSFRaNkQyZkZBM3NoOCtRU0ZlCnZobkhaVFpZK2d2eGRLUXFBT2U5NlllajNkZTlJK0ZXbFpBTFNRVnJ4dGpUYklIeG12ND0KLS0tLS1FTkQgQ0VSVElGSUNBVEUtLS0tLQo=
  19.   client-key-data: LS0tLS1CRUdJTiBSU0EgUFJJVkFURSBLRVktLS0tLQpNSUlFb3dJQkFBS0NBUUVBenBSZ0oydlR2dUh4VU1MM2xDQUlTMUsweXorWi81N0ltbmZxZGNzbVNkTytrdFIyClFCVGtTMlI1M2VYanVrVTU1M2FQOXkzcFZYcThuT2hLTmFPcjJ1S1grejF1a2k0Vmh3Z0RnR09GZ2I5eVVTM0oKeGZzdXhXY21jY1JYa0crekJWYkdONFJRN2JOTkt0TmIzdlUrMzR1d1BKM0Fid2dyWUNqaFAxVnAwZGVhdlRZQQoxOExQcmdhUWRQbUhyUTRYS3B0UlZaV3pwR2YrZEpHQmZJQS81UkdlQTJkQStUdEpFQ0lIV2pIQ3QwSEpIcSt4CndjOFE3T1hSZ25oVFRNcXh0c0JwL2FSN3pWdHNhSWJNWkdUYW85UGFZN1FqdVp0RlNJaWRYR2k2Y3lXZElMQlUKakx6Z1NjZnZFMnRCdHd3VS9VMlhKT3BaaGV2SVYxUDJ4NldVOVFJREFRQUJBb0lCQUV1Z0ZmTllqaFA3TXhTVgp5M3oyblJLMkhHbXJ4dnpGYkRyZ1czenorZmhkQkE5TXFGMmRTRll4V2t2WnRSeWo2eWJKU0xyOG04Y25QNVZSCmxKaythZE9mMEhPeGNhRWlMYzlaSjY4QXdBZFh4c25oTVZUQk44WWNsUDVoR28xTjF3UEZXSnRLWFRZbnhjQS8KMEFvM1RlVVlobFFxakNBWnBZZDJiNzkzelYxOEgzdGpyUkZpRFlJUGx0eGp0UXhDaDJhM1BVOEJFbWxQU2RFKwpPdHJvOEhuMlFWdG9VaFJ1c0lIQTVNMldPK3oyWnJ5SlNYNjZWRmx2OE40OHRNMG1DNmZCN1dYc2dHTDYvSms4CkxqbXd5VUJNenlJTXVXdHNpMlc3cUdSTURIblVJRnZVdGRiSEVkL3FFRXNnU2M1WTZaRlFveExFdnBuMlZlYWEKai9PdUV3RUNnWUVBL2cvNXJLNHBic0tsd0pwMmw0Q3VBMGEzbXJJNDhiQVVwc1JzOXRaVmtXQTFuVm41SGtoagpLaElhMDB2N1cyRm9JUjV1SHFLMjNzZ3pjdHVEd2dkMWRBVnZKRUxFRk50ak9BYXBFOXJyblc2MWk0bHFXZ1NVCnp2aEtmYXdXQXA4Z2YzbGFjYmpJeTQ0QWgrVGlXbjkweVVPSkxTRXRDazZwTW9aZklBNTlBTmtDZ1lFQTBDZXkKTldEV2JKSHpNcE1mSW9tQ2NINlVYcEJDTWV4MFFrR3ZJQnI4ak5zQXdoTHJZMWdsSm1uKzhFdGlieWVQTG1vYQp3WTdncllsSzR2dDlTTjAvSDZzeWZMUmVhZ1lVTlREY01LbnI3eGNCb2V3QW1JbURNRFVGdURzUzhjKysxdmw4CkhEMDh6V0hEL0lKd2IrVmJ6Szc4OWxBajVsSHMrQVBUdTlwaW8zMENnWUIyQXlHc3JuR2NlMW5XNzJqcTB1RUIKc0pXVWkvaWJlM2o4UmYxL1l1djRUVUphUnZMS3VFRW54NlVpUlFjSzJXSXZFQjJDcVg1Y1dZNWNhYzc0RDlMbApBNmt1cEx6RUcyd3BHQjd0bENFaHpjMFNkZEFxNURuak1iNFlSaGtyT3BNejQwQzUxbVdlOStVVE9xUlIrU1pjClhyeVhjL09oK0F2cjVqTEZoelZWY1FLQmdIcW5PV29ja3B6TTcybllxUnIzdmdXOWdIMnNNV1VyZUdIbVJHUDkKb3R6NDJ4eUFlM1ZCWmpxWmNLQjFPeDVXU0JkSWJGV3JkQmF0ZEpRRkxwQzExZEU2Vm5pRzY2ODd2OEtMOU9Nego3Uk1vRWswd1BEV2xxY2pKSllLbVJJWjZMSENOOTZUSUxNQzBvQUIxZC8xblA4MS9PdzJFc1hLd3lacG0zdWV0ClNqd2RBb0dCQUlBdmtKSFMwbElNdlExNWJzQWhWbkpLc295RTZ2Vm8yVmtMNS9VdUlrYzdtMGVDKzZ1WWNEMzEKWnl6ZUZzcEZFbG1MbERiZXFueTdHMEY0d09PTEhoZFk2SUxmdkRpakhIU1VxbFZiWGp2cExieWRoVzFSNlhXRApHQStZU3c0akEwY1lEZzFsaU1zSzlqd2plVmJVNWxTRzZzMHN0V2ZkK2xVVXVSOThrNFJVCi0tLS0tRU5EIFJTQSBQUklWQVRFIEtFWS0tLS0tCg==

D:\codes\k8sclient\list.go

  1.   package main
  2.    
  3.   import (
  4.   "context"
  5.   "fmt"
  6.   "log"
  7.    
  8.   metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  9.   "k8s.io/client-go/kubernetes"
  10.   "k8s.io/client-go/tools/clientcmd"
  11.   )
  12.    
  13.   func list() {
  14.   configPath := "etc/kube.conf"
  15.   config, err := clientcmd.BuildConfigFromFlags("", configPath)
  16.   if err != nil {
  17.   log.Fatal(err)
  18.   }
  19.   clientset, err := kubernetes.NewForConfig(config)
  20.    
  21.   if err != nil {
  22.   log.Fatal(err)
  23.   }
  24.    
  25.   nodeList, _ := clientset.CoreV1().Nodes().List(context.TODO(), metaV1.ListOptions{})
  26.    
  27.   fmt.Println("node:")
  28.   for _, node := range nodeList.Items {
  29.   fmt.Printf("%s\t%s\t%s\t%s\t%s\t%s\t%s\n%s\n",
  30.   node.Name,
  31.   node.Status.Phase,
  32.   node.Status.Addresses,
  33.   node.Status.NodeInfo.OSImage,
  34.   node.Status.NodeInfo.KubeletVersion,
  35.   node.Status.NodeInfo.OperatingSystem,
  36.   node.Status.NodeInfo.Architecture,
  37.   node.CreationTimestamp,
  38.   )
  39.   }
  40.    
  41.   namespaceList, _ := clientset.CoreV1().Namespaces().List(context.TODO(), metaV1.ListOptions{})
  42.    
  43.   fmt.Println("namespace:")
  44.   for _, namespace := range namespaceList.Items {
  45.   fmt.Println(namespace.Name, namespace.CreationTimestamp, namespace.Status.Phase)
  46.   }
  47.    
  48.   servicesList, _ := clientset.CoreV1().Services("").List(context.TODO(), metaV1.ListOptions{})
  49.   fmt.Println("service:")
  50.    
  51.   for _, service := range servicesList.Items {
  52.   fmt.Println(service.Namespace, service.Name, service.Spec.Type, service.CreationTimestamp, service.Spec.ClusterIP, service.Spec.Ports)
  53.   }
  54.    
  55.   deploymentList, _ := clientset.AppsV1().Deployments("").List(context.TODO(), metaV1.ListOptions{})
  56.    
  57.   fmt.Println("deployment:")
  58.   for _, deployment := range deploymentList.Items {
  59.   fmt.Println(deployment.Namespace, deployment.Name, deployment.Labels, deployment.CreationTimestamp, deployment.Spec.Selector.MatchLabels, deployment.Status.Replicas, deployment.Status.AvailableReplicas)
  60.   }
  61.   }

k8s client创建资源

D:\codes\k8sclient\createDeploy.go

  1.   package main
  2.    
  3.   import (
  4.   "context"
  5.   "fmt"
  6.    
  7.   appsV1 "k8s.io/api/apps/v1"
  8.   coreV1 "k8s.io/api/core/v1"
  9.   metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  10.   "k8s.io/client-go/kubernetes"
  11.   "k8s.io/client-go/tools/clientcmd"
  12.   )
  13.    
  14.   func createDeploy() {
  15.   configPath := "etc/kube.conf"
  16.   config, _ := clientcmd.BuildConfigFromFlags("", configPath)
  17.   clientset, _ := kubernetes.NewForConfig(config)
  18.    
  19.   namespace := "default"
  20.   var replicas int32 = 3
  21.    
  22.   deployment := &appsV1.Deployment{
  23.   ObjectMeta: metaV1.ObjectMeta{
  24.   Name: "nginx",
  25.   Labels: map[string]string{
  26.   "env": "dev",
  27.   },
  28.   },
  29.   Spec: appsV1.DeploymentSpec{
  30.   Replicas: &replicas,
  31.   Selector: &metaV1.LabelSelector{
  32.   MatchLabels: map[string]string{
  33.   "app": "nginx",
  34.   "env": "dev",
  35.   },
  36.   },
  37.   Template: coreV1.PodTemplateSpec{
  38.   ObjectMeta: metaV1.ObjectMeta{
  39.   Name: "nginx",
  40.   Labels: map[string]string{
  41.   "app": "nginx",
  42.   "env": "dev",
  43.   },
  44.   },
  45.   Spec: coreV1.PodSpec{
  46.   Containers: []coreV1.Container{
  47.   {
  48.   Name: "nginx",
  49.   Image: "nginx:1.16.1",
  50.   Ports: []coreV1.ContainerPort{
  51.   {
  52.   Name: "http",
  53.   Protocol: coreV1.ProtocolTCP,
  54.   ContainerPort: 80,
  55.   },
  56.   },
  57.   },
  58.   },
  59.   },
  60.   },
  61.   },
  62.   }
  63.    
  64.   deployment, err := clientset.AppsV1().Deployments(namespace).Create(context.TODO(), deployment, metaV1.CreateOptions{})
  65.    
  66.   fmt.Println(err, deployment)
  67.   }

D:\codes\k8sclient\createService.go

  1.   package main
  2.    
  3.   import (
  4.   "context"
  5.   "fmt"
  6.    
  7.   coreV1 "k8s.io/api/core/v1"
  8.   metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  9.   "k8s.io/client-go/kubernetes"
  10.   "k8s.io/client-go/tools/clientcmd"
  11.   )
  12.    
  13.   func createService() {
  14.   configPath := "etc/kube.conf"
  15.   config, _ := clientcmd.BuildConfigFromFlags("", configPath)
  16.   clientset, _ := kubernetes.NewForConfig(config)
  17.    
  18.   namespace := "default"
  19.   service := &coreV1.Service{
  20.   ObjectMeta: metaV1.ObjectMeta{
  21.   Name: "nginx-service",
  22.   Labels: map[string]string{
  23.   "env": "dev",
  24.   },
  25.   },
  26.   Spec: coreV1.ServiceSpec{
  27.   Type: coreV1.ServiceTypeNodePort,
  28.   Selector: map[string]string{
  29.   "env": "dev",
  30.   "app": "nginx",
  31.   },
  32.   Ports: []coreV1.ServicePort{
  33.   {
  34.   Name: "http",
  35.   Port: 80,
  36.   Protocol: coreV1.ProtocolTCP,
  37.   },
  38.   },
  39.   },
  40.   }
  41.   service, err := clientset.CoreV1().Services(namespace).Create(context.TODO(), service, metaV1.CreateOptions{})
  42.    
  43.   fmt.Println(err, service)
  44.   }

D:\codes\k8sclient\deleteResource.go

  1.   package main
  2.    
  3.   import (
  4.   "context"
  5.    
  6.   metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  7.   "k8s.io/client-go/kubernetes"
  8.   "k8s.io/client-go/tools/clientcmd"
  9.   )
  10.    
  11.   func main() {
  12.   configPath := "etc/kube.conf"
  13.   config, _ := clientcmd.BuildConfigFromFlags("", configPath)
  14.   clientset, _ := kubernetes.NewForConfig(config)
  15.    
  16.   namespace := "default"
  17.    
  18.   name, serviceName := "nginx", "nginx-service"
  19.    
  20.   clientset.AppsV1().Deployments(namespace).Delete(context.TODO(), name, metaV1.DeleteOptions{})
  21.    
  22.   clientset.CoreV1().Services(namespace).Delete(context.TODO(), serviceName, metaV1.DeleteOptions{})
  23.    
  24.   // clientset.ExtensionsV1beta1().Ingresses()
  25.   }

D:\codes\k8sclient\editDeploy.go

  1.   package main
  2.    
  3.   import (
  4.   "context"
  5.   "fmt"
  6.    
  7.   metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  8.   "k8s.io/client-go/kubernetes"
  9.   "k8s.io/client-go/tools/clientcmd"
  10.   )
  11.    
  12.   func editDeploy() {
  13.   configPath := "etc/kube.conf"
  14.   config, _ := clientcmd.BuildConfigFromFlags("", configPath)
  15.   clientset, _ := kubernetes.NewForConfig(config)
  16.    
  17.   namespace := "default"
  18.    
  19.   var replicas int32 = 1
  20.    
  21.   name := "nginx"
  22.    
  23.   deployment, err := clientset.AppsV1().Deployments(namespace).Get(context.TODO(), name, metaV1.GetOptions{})
  24.    
  25.   deployment.Spec.Replicas = &replicas
  26.   deployment.Spec.Template.Spec.Containers[0].Image = "nginx:1.14"
  27.    
  28.   deployment, err = clientset.AppsV1().Deployments(namespace).Update(context.TODO(), deployment, metaV1.UpdateOptions{})
  29.   fmt.Println(err, deployment)
  30.   }

D:\codes\k8sclient\editReplicas.go

  1.   package main
  2.    
  3.   import (
  4.   "context"
  5.   "fmt"
  6.    
  7.   metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  8.   "k8s.io/client-go/kubernetes"
  9.   "k8s.io/client-go/tools/clientcmd"
  10.   )
  11.    
  12.   func editReplicas() {
  13.   configPath := "etc/kube.conf"
  14.   config, _ := clientcmd.BuildConfigFromFlags("", configPath)
  15.   clientset, _ := kubernetes.NewForConfig(config)
  16.    
  17.   namespace := "default"
  18.    
  19.   name := "nginx"
  20.    
  21.   scale, err := clientset.AppsV1().Deployments(namespace).GetScale(context.TODO(), name, metaV1.GetOptions{})
  22.    
  23.   scale.Spec.Replicas = 2
  24.   scale, err = clientset.AppsV1().Deployments(namespace).UpdateScale(context.TODO(), name, scale, metaV1.UpdateOptions{})
  25.   fmt.Println(err, scale)
  26.   }

https://github.com/yunixiangfeng/go-demo/tree/main/k8sclient

go-demo/cmdb at main · yunixiangfeng/go-demo · GitHub

ELK日志系统

搜索引擎基础

Elasticsearch基础

Logstash基础

kibana基础

Go语言并发编程

go并发模型

并发合并文件

channel

并发安全性

多路复用

HTTP标准库解读

实现自己的router

http协议

go http编程

router

验证器和中间件

GIN 

Socket编程

网络通信原理

聊天室的实现

tcp编程

tcp面向字节流和udp理论

TLS和websocket理论

websocket编程方式 

Go语言操作数据库

mysql基础理论 

mysql最佳实践

go语言操作mysql

第三方sql-builder

自己实现sql

gorm

go语言操作mongo

文件中转站

工具开发

以系统方式开发

项目工程

Demo后端开发

 

DemoIoc后端开发

RPC

RPC入门

Protobuf编解码

proto3语法

GRPC

grpc入门

 

CMDB API

框架支持GRPC 

CMDB 

云资源Provider

云凭证管理

云资源同步API

用户中心

用户中心 

审计中心

消息队列技术与Kafka 

审计中心

Web 入门

JavaScript基础 

Web入门基础-HTML

Web入门基础-CSS

Web入门基础-浏览器

一、 API Server开发

API Server Pipeline开发 

二、 Pipeline调度器开发

Informer和服务注册 

三、订阅SCM事件

调度器Controller开发

Step调度器开发与Node开发

API Server 订阅SCM事件

 Go语言并发编程 

数据安全与加解密算法.

1.对称加密

DES数组分级

DES子密钥生成

DES加密过程

S盒替换

分组模式

AES

 

2.非对称加密

RSA

对称加密和非对称加密结合使用

RSA加密过程

椭圆曲线加密

 

3.哈希算法

哈希函数的基本特征

SHA1

MD5

哈希函数的应用

数字签名

 

密码学api

数据结构与算法

1.链表

单向链表

  1.   package main
  2.    
  3.   import "fmt"
  4.    
  5.   // 链表中的一个元素
  6.   type Node struct {
  7.   Info int
  8.   Next *Node
  9.   }
  10.    
  11.   // 链表
  12.   type List struct {
  13.   Head *Node
  14.   Len int
  15.   }
  16.    
  17.   func (list *List) Add(ele int) {
  18.   node := &Node{Info: ele, Next: nil}
  19.   if list.Len == 0 {
  20.   list.Head = node
  21.   } else {
  22.   head := list.Head
  23.   for i := 1; i < list.Len; i++ {
  24.   head = head.Next
  25.   }
  26.   head.Next = node
  27.   }
  28.   list.Len += 1
  29.   }
  30.   func (list *List) Travers() {
  31.   if list.Len == 0 {
  32.   return
  33.   }
  34.   head := list.Head
  35.   fmt.Println(head.Info)
  36.   for i := 1; i < list.Len; i++ {
  37.   head = head.Next
  38.   fmt.Println(head.Info)
  39.   }
  40.   }
  41.   func main() {
  42.   list := List{}
  43.   list.Add(1)
  44.   list.Add(8)
  45.   list.Add(4)
  46.   list.Add(3)
  47.   list.Add(5)
  48.   list.Travers()
  49.   }
  1.   func (list *List) Add(ele int) {
  2.   node := &Node{Info: ele, Next: nil}
  3.   if list.Len == 0 {
  4.   list.Head = node
  5.   list.Tail = node
  6.   } else {
  7.   list.Tail.Next = node
  8.   list.Tail = node
  9.   }
  10.   list.Len += 1
  11.   }

 

链表的应用:LRU缓存淘汰
·LRU(Least Recently Used)最近最少使用思路:缓存的kev放到链表中,头部的元素表示最近刚使用如果命中缓存,从链表中找到对应的key,移到链表头部
如果没命中缓存:
如果缓存容量没超,放入缓存,并把key放到链表头部.
如果超出缓存容量,删除链表尾部元素,再把key放到链表头部

LRU和超时缓存

循环链表

 

RING添加元素

RING的应用:基于滑动窗口的统计
最近100次接口调用的平均耗时、最近10笔订单的平均值最近30个交易日股票的最高点
ring的容量即为滑动窗口的大小,把待观察变量按时间顺序不停地写入ring即可

 

2.栈

先进后出
3.堆

 

4.Trie树

根节点是总入口,不存储字符
对于英文,第个节点有26个子节点,子节点可以存到数组里;中文由于汉字很多,用数组存子节点太浪费内存,可以用map存子节点从根节点到叶节点的完整路径是一个term从根节点到某个中间节点也可能是一个term,即一个term可能是另一个term的前缀

斐波那契数列

递归造成计算浪费

用栈解除递归

斐波那契数列非递归实现

 

堆的应用

堆的底层表示

堆是一棵二叉树。大根堆:任意节点的值都大于等于其子节点。反之为小根堆。用数组来表示堆,下标为i的结点的父结点下标为(i-1)/2,其左右子结点分别为(2i+ 1)、(2i+ 2)。

构建堆

每当有元素调整下来时,要对以它为父节点的三角形区域进行调整

删除堆顶

向下调整

用堆实现超时缓存
把超时的元素从缓存中删除
1.按key的到期时间把key插入小根堆中
2周期扫描堆顶元素,如果它的到期时间早于当前时刻,则从堆和缓存中删除,然后向下调整堆

求集合中最大的K个元素
1.用集合的前K个元素构建小根堆
2.逐一遍历集合的其他元素,如果比堆顶小直接丢弃;否则替换掉堆顶,然后向下调整堆

把超时的元素从缓存中删除
1.按key的到期时间把key插入小根堆中
2.周期扫描堆顶元素,如果它的到期时间早于当前时刻,则从堆和缓存中删除,然后向下调整堆

堆的实现

Trie树

根节点是总入口,不存储字符
对于英文,第个节点有26个子节点,子节点可以存到数组里;中文由于汉字很多,用数组存子节点太浪费内存,可以用map存子节点从根节点到叶节点的完整路径是一个term从根节点到某个中间节点也可能是一个term,即一个term可能是另一个term的前缀

1.实现数字签名
2.用map和链表实现LRU缓存
3.用map和堆表实现超时缓存

并发编程

go并发模型

并发合并文件

channel

并发安全性

多路复用

web开发

http标准库

实现router

http协议

go http编程

router

验证器和中间件

Gin

Socket编程

网络通信原理

聊天室的实现

tcp编程

tcp面向字节流和udp

TLS和websocket 

websocket 编程方式

Go操作数据库

mysql基础

mysql实践

go操作mysql

sql-builder

自己实现sql

gorm

go操作mongo

文件中转站

简易版工具开发

以系统方式开发

项目工程

demo简化版

demo后端开发

demo IOC版

demo后端开发

RPC入门

rpc入门

protobuf编解码

proto3语法入门

grpc入门

框架支持grpc

cmdb api

云资源provider

云凭证管理

云资源同步api

用户中心

用户中心

登录认证

权限判定

审计中心

消息队列kafka

审计中心

web入门

javascript基础

web基础html

web基础css

web基础浏览器

vue入门

vue基础

vue路由与状态管理

项目前端框架

登陆页面

项目404页面

项目导航页面

项目前端

主机列表页面

cmdb主机页面

cmdb搜索页面

cmdb同步页面

总线和缓存

web和prometheus二次开发

prometheus概念

exporter开发

kubernetes二次开发

Kubernetes 简介与client-go使用

基于client-go 的多集群管理平台

Kubernetes Operator 开发

kubernetes二次开发

API Server开发

API Server pipeline开发

pipeline调度器开发

informer和服务注册

订阅SCM事件

调度器controller开发

step调度器开发和node开发

api server订阅scm事件

   

标签:架构设计,协程,string,err,fmt,Println,user,go,name
From: https://www.cnblogs.com/add1188/p/17825768.html

相关文章

  • go 1.6 废弃 io/ioutil 包后的替换函数
      go1.6废弃io/ioutil 包后的替换函数 io/ioutil替代 ioutil.ReadAll->io.ReadAllioutil.ReadFile->os.ReadFileioutil.ReadDir->os.ReadDir//othersioutil.NopCloser->io.NopCloserioutil.ReadDir->os.ReadDirioutil.TempDir->os.Mkdi......
  • 【1.0】Go语言介绍及引入
    【一】Go语言介绍Go语言是Google公司在2007开发一种静态强类型、编译型语言,并在2009年正式对外发布。静态强类型语言需要先编译再执行比如C、C#、Java等语言需要先将代码编译成不同平台的可执行文件,才能在不同平台上运行需要解释器比如Python、PHP、node.js等语言,......
  • 【4.0】Go语言语法基础之函数
    【一】函数基础【1】语法func关键字函数名(形参1形参1的类型,形参2形参2的类型)(返回值类型){函数体(函数体的内容和缩进无关,只要是在大括号内,都是函数体内容)}在Python中需要先定义函数再使用在Go中不需要先定义再使用funcmain(){}【2】无参数无返回值......
  • 【3.0】Go语言语法初识之变量
    【零】注释语法注释就是对代码的解释和说明,其目的就是让人们更加轻松的了解代码。注释是开发人员的一个重要的习惯。单行注释使用//开头多行注释使用/*开头*/结尾//package定义包名main包名packagemain//import引用库fmt库名import"fmt"//func定......
  • go.mod file not found in current directory or any parent directory; see 'go help
    go.modfilenotfoundincurrentdirectoryoranyparentdirectory;see'gohelpmodules'(exitstatus1)原因:目录少缺少 go.mod文件。解决方法:在终端中输入:gomodinitmain 其中main是模块名。 ......
  • GoKIT v2.1是一种基于云的物联网开发平台,旨在帮助开发者快速构建物联网应用程序。
    GoKITv2.1是一种基于云的物联网开发平台,旨在帮助开发者快速构建物联网应用程序。它提供了一组简单易用的工具和API,使开发者能够轻松地与各种类型的设备和传感器进行交互,并实时处理数据。GoKITv2.1的主要特点包括:设备管理:可以轻松管理连接到平台的设备,包括添加、删除和重新配置设......
  • Go中字符串处理:fmt.Sprintf与string.Builder的比较
    在Go语言中,我们通常会遇到两种主要的方式来处理和操作字符串:使用fmt.Sprintf函数和string.Builder类型。尽管两者都可以实现字符串的格式化和连接,但它们在性能和用法上有一些关键区别。1.fmt.Sprintffmt.Sprintf是一个函数,它根据提供的格式化字符串和参数列表,将它们格式化为一......
  • godot常用C#代码
    Godot常用C#代码注:本文记录的是我个人认为很常用但是容易忘记的C#代码。生成实例:生成实例的对象必须是PackedScene类型生成实例如果想用其它类型存储需要强制转换,即在变量名前括号加变量名,或用az强转代码示例:usingGodot;usingSystem;publicpartialclassworl......
  • The governance measures of marine oil pollution
    Thegovernancemeasures(1).Preventivemeasures.Preventionisoneofthemosteffectivecontrolmethods,includingthefollowingaspects:a.Strengtheningmonitorandcontrolsystem,improvingthesoundmonitoringsystem,andestabilishingthe real-time......
  • 一文快速实战Kotlin协程与Flow
    前言不知道大家有没有跟我一样的感受:即使自己用心在网上学过协程和Flow了,但过了一段时间就又忘掉了。这大部分的原因其实是因为我们缺少实战。我平时工作里根本就接触不到协程和Flow,自己又不敢硬往上写,万一出问题了咋整?所以一直就处于理论学习阶段,导致我学了就跟没学一样。今天就带......