文章
文章用户文档快讯圈子网址导航

Go语言系列（九）- Socket编程和Redis

释放双眼，带上耳机，听听看~！

Socket编程

一、socket编程概述

什么是socket编程？ socket编程是计算机PC机器上2个程序通过一个双向的通信连接实现数据的交互，这个连接的一端就是一个socket。socket的翻译意思上还有个插座的概念，其实，也可以很形象的比喻为插座插上去了就有通电了（网络通了）。
socket编程其实作为UNIX系统的进程间通信机制，通常称为“套接字”，用来描述IP地址和端口的集合，在unix系统下是一个通信的句柄（文件描述符，因为UNIX下所有都是文件）。

UNIX socket编程的流程大概如下：

  • 服务端：socket()，bind()，listen()，accept()，read()/write()，close()
  • 服务端：socket()， connect()，read()/write()，close()

二、Go语言socket编程库

go语言的基础包中，网络包net包含了很多网络I/O，TCP/IP，UDP，域名解析，Unix 域套接字等。

虽然提供的都是直接面对很底层的网络I/O访问，但是主要的TCP通信的接口也是封装得比较简单，好用，包括有：

  • 客户端连接使用的Dial方法
  • 服务端进行监听使用的Listen方法
  • 服务端进行接受链接的Accept方法
  • 封装了连接对象Conn类型

三、客户端和服务端

Go语言系列（九）- Socket编程和Redis

 1. 服务器处理流程

  • a. 监听端口

  • b. 接收客户端的链接

  • c. 创建goroutine,处理该链接

2.  客户端处理流程

  • a. 建立与服务器的链接

  • b. 进行数据收发

  • c. 关闭链接

3. 服务端代码



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
1package main

2

3import (

4   "fmt"

5   "net"

6)

7

8func main() {

9   fmt.Println("start server...")

10  listen, err := net.Listen("tcp", "0.0.0.0:50000")

11  if err != nil {

12      fmt.Println("listen failed, err:", err)

13      return

14  }

15  for {

16      conn, err := listen.Accept()

17      if err != nil {

18          fmt.Println("accept failed, err:", err)

19          continue

20      }

21      go process(conn)

22  }

23}

24func process(conn net.Conn) {

25  defer conn.Close()

26  for {

27      buf := make([]byte, 512)

28      n, err := conn.Read(buf)

29      if err != nil {

30          fmt.Println("read err:", err)

31          return

32      }

33

34      fmt.Printf(string(buf[0:n]))

35  }

36}

37

4. 客户端代码



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
1package main

2

3import (

4   "bufio"

5   "fmt"

6   "net"

7   "os"

8   "strings"

9)

10

11func main() {

12

13  conn, err := net.Dial("tcp", "localhost:50000")

14  if err != nil {

15      fmt.Println("Error dialing", err.Error())

16      return

17  }

18

19  defer conn.Close()

20  inputReader := bufio.NewReader(os.Stdin)

21  for {

22      input, _ := inputReader.ReadString('\n')

23      trimmedInput := strings.Trim(input, "\r\n")

24      if trimmedInput == "Q" {

25          return

26      }

27      _, err = conn.Write([]byte(trimmedInput))

28      if err != nil {

29          return

30      }

31  }

32}

33

5. 发送http请求



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
1package main

2

3import (

4   "fmt"

5   "io"

6   "net"

7)

8

9func main() {

10

11  conn, err := net.Dial("tcp", "www.baidu.com:80")

12  if err != nil {

13      fmt.Println("Error dialing", err.Error())

14      return

15  }

16  defer conn.Close()

17  msg := "GET / HTTP/1.1\r\n"

18  msg += "Host:www.baidu.com\r\n"

19  msg += "Connection:keep-alive\r\n"

20  // msg += "User-Agent:Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/56.0.2924.87 Safari/537.36\r\n"

21  msg += "\r\n\r\n"

22

23  //io.WriteString(os.Stdout, msg)

24  n, err := io.WriteString(conn, msg)

25  if err != nil {

26      fmt.Println("write string failed, ", err)

27      return

28  }

29  fmt.Println("send to baidu.com bytes:", n)

30  buf := make([]byte, 4096)

31  for {

32      count, err := conn.Read(buf)

33      fmt.Println("count:", count, "err:", err)

34      if err != nil {

35          break

36      }

37      fmt.Println(string(buf[0:count]))

38  }

39}

40

Redis

一、Redis简介

redis是个开源的高性能的key-value的内存数据库，可以把它当成远程的数据结构。支持的value类型非常多，比如string、list（链表）、set（集合）、hash表等等。redis性能非常高，单机能够达到15w qps，通常适合做缓存。

 1. 特点

  • 支持更多数据类型 

和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set 有序集合)和hash（哈希类型）。[1]

  • 支持复杂操作 

这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，Redis支持各种不同方式的排序。[2]

  • 支持主从同步。 

与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是Redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。数据可以从主服务器向任意数量的从服务器上同步，从服务器可以是关联其他从服务器的主服务器。这使得Redis可执行单层树复制。从盘可以有意无意的对数据进行写操作。由于完全实现了发布/订阅机制，使得从数据库在任何地方同步树时，可订阅一个频道并接收主服务器完整的消息发布记录。同步对读取操作的可扩展性和数据冗余很有帮助。

2.  常见使用场景

  • 高并发下数据缓存。 比如在某个场景下，大量日志同时写入数据库会给服务器带来巨大压力，这时可以先将数据写入redis中，再由redis写入数据库，减轻同时写入压力。
  • 热点信息快速显示。假设现在有一个新闻首页，需要快速显示各栏目前20条热点新闻，如果直接查询数据库，在大量用户同时访问下，会消耗极大数量的数据库请求。这时就可以用redis来优化，在新闻录入的时候将标题、时间和来源写入redis中，客户端访问时，可以从内存中一次性取出当天热单新闻列表，极大地提高请求速度和节约了服务器开销。
  • 保存会话信息。可以将登录后用户信息缓存入redis并同时设置key过期时间,这样后台api过滤请求时，就可以从内存中读取用户信息，而且redis的过期机制，天然支持用户身份有效期校验，用起来十分方便。
  • 统计计数。比如系统中常见一个功能是限制同一用户固定时间段内的登录次数或者所有请求次数，这时就可以以用户id为key，次数值为value，将计数信息缓存起来，并且有INCRBY命令原生支持。
  • 其他。Redis的应用场景十分广发，队列、发布订阅、统计分析等等，可以看看其他文章的介绍说明。

Redis的出现，很大程度补偿了memcached这类key/value存储的不足，在部 分场合可以对关系数据库起到很好的补充作用。它提供了Java，C/C++，C#，PHP，JavaScript，Perl，Object-C，Python，Ruby，Erlang等客户端，使用很方便。Redis的官网地址，非常好记，是redis.io。目前，Vmware在资助着Redis项目的开发和维护。

二、Redis的主要数据结构

Redis主要有五种基本数据结构，满足了绝大多数缓存结构的需要，如果你在使用一种结构存储时感觉别扭时，很有可能是选错了存储结构，可以考虑一下其他结构的正确实现。

  • String ，可以是字符串、整数和浮点数。如果是序列化数据，并涉及到修改操作的话，不推荐用string，可以考虑用Hash
  • Hash, key-value 对象，可以存放对象数据，比如用户信息之类。
  • List，有序数据集合，元素可以重复，用LPUSH、LPOP、RPUSH、RPOP等指令组合可以实现栈和队列操作。
  • Set，无序集合，元素唯一。
  • Sorted Set，Sort的有序版，可以设定Score值来决定元素排序，适合用户排名这样的业务场景。

 二、Redis的使用

 1. redigo

redigo是GO语言的一个redis客户端实现。项目位于https://github.com/garyburd/redigo

 2. 安装redigo

redigo没有其他依赖项，可以直接通过go get进行安装 



1
2
1go get github.com/garyburd/redigo/redis

2

 3. 连接redis



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
1package main

2

3import (

4   "fmt"

5   "github.com/garyburd/redigo/redis"

6)

7

8func main() {

9   c, err := redis.Dial("tcp", "localhost:6379")

10  if err != nil {

11      fmt.Println("conn redis failed,", err)

12      return

13  }

14

15  defer c.Close()

16}

17

 4. 建立连接池

Redigo Pool 结构维护一个 Redis 连接池。应用程序调用 Get 方法从池中获取连接，并使用连接的 Close 方法将连接的资源返回到池中。一般我们在系统初始化时声明一个全局连接池，然后在需要操作redis时获得连接，执行指令。



1
2
3
4
5
6
7
8
9
10
11
12
13
14
1pool := &redis.Pool{

2        MaxIdle:     3, /*最大的空闲连接数*/

3        MaxActive:   8, /*最大的激活连接数*/

4        Dial: func() (redis.Conn, error) {

5            c, err := redis.Dial("tcp", "链接地址，例如127.0.0.1:6379", redis.DialPassword("密码"))

6            if err != nil {

7                return nil, err

8            }

9            return c, nil

10        },

11}

12c:=pool.Get()

13defer c.Close()

14

Go语言系列（九）- Socket编程和RedisGo语言系列（九）- Socket编程和Redis



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
1package main

2

3import (

4    "fmt"

5

6    "github.com/garyburd/redigo/redis"

7)

8

9var pool *redis.Pool

10

11func init() {

12    pool = &redis.Pool{

13        MaxIdle:     16, /* 最大的空闲连接数 */

14        MaxActive:   0,  /* 最大的激活连接数 */

15        IdleTimeout: 300,

16        Dial: func() (redis.Conn, error) {

17            c, err := redis.Dial("tcp", "localhost:6379", redis.DialPassword("0000"))

18            if err != nil {

19                return nil, err

20            }

21            return c, nil

22        },

23    }

24}

25

26func main() {

27

28    c := pool.Get()

29    defer c.Close()

30

31    _, err := c.Do("Set", "abc", 100)

32    if err != nil {

33        fmt.Println(err)

34        return

35    }

36

37    r, err := redis.Int(c.Do("Get", "abc"))

38    if err != nil {

39        fmt.Println("get abc failed,", err)

40        return

41    }

42

43    fmt.Println(r)

44    pool.Close()

45}

46

redis连接池实例

 5.  执行指令

查看源码，发现Conn 接口有一个执行 Redis 命令的通用方法：



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
1//gomodule/redigo/redis/redis.go

2

3// Conn represents a connection to a Redis server.

4type Conn interface {

5    // Close closes the connection.

6    Close() error

7

8    // Err returns a non-nil value when the connection is not usable.

9    Err() error

10

11    // Do sends a command to the server and returns the received reply.

12    Do(commandName string, args ...interface{}) (reply interface{}, err error)

13

14    // Send writes the command to the client's output buffer.

15    Send(commandName string, args ...interface{}) error

16

17    // Flush flushes the output buffer to the Redis server.

18    Flush() error

19

20    // Receive receives a single reply from the Redis server

21    Receive() (reply interface{}, err error)

22}

23

 http://redis.io/commands 中的 Redis 命令参考列出了可用的命令。do的参数和redis-cli命令参数格式一致，比如SET key value EX 360 对应函数调用为Do("SET", "key", "value"，"EX",360)，常用的命令示例有：　　



1
2
3
4
5
6
7
8
9
10
11
12
13
1c := pool.Get()

2defer c.Close()

3//存值,

4_, err := c.Do("SET", "key", "value")

5//设置过期时间

6_, err := c.Do("SET", "key", "value"，"EX",360)

7//存int

8_, err := c.Do("SET", "key", 2)

9

10//取值

11v,err:=redis.String(c.Do("GET","key"))

12bytes, err := redis.Bytes(c.Do("GET", "key"))

13

Go语言系列（九）- Socket编程和RedisGo语言系列（九）- Socket编程和Redis



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
1package main

2

3import (

4    "fmt"

5

6    "github.com/garyburd/redigo/redis"

7)

8

9func main() {

10    var p *int

11    var a int

12    p = &a

13    *p = 0

14

15    c, err := redis.Dial("tcp", "localhost:6379")

16    if err != nil {

17        fmt.Println("conn redis failed,", err)

18        return

19    }

20

21    defer c.Close()

22    _, err = c.Do("Set", "abc", 100)

23    if err != nil {

24        fmt.Println(err)

25        return

26    }

27

28    r, err := redis.Int(c.Do("Get", "abc"))

29    if err != nil {

30        fmt.Println("get abc failed,", err)

31        return

32    }

33

34    fmt.Println(r)

35}

36

set操作

Go语言系列（九）- Socket编程和RedisGo语言系列（九）- Socket编程和Redis



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
1package main

2

3import (

4    "fmt"

5

6    "github.com/garyburd/redigo/redis"

7)

8

9func main() {

10    c, err := redis.Dial("tcp", "localhost:6379")

11    if err != nil {

12        fmt.Println("conn redis failed,", err)

13        return

14    }

15

16    defer c.Close()

17    _, err = c.Do("MSet", "abc", 100, "efg", 300)

18    if err != nil {

19        fmt.Println(err)

20        return

21    }

22

23    r, err := redis.Ints(c.Do("MGet", "abc", "efg"))

24    if err != nil {

25        fmt.Println("get abc failed,", err)

26        return

27    }

28

29    for _, v := range r {

30        fmt.Println(v)

31    }

32}

33

mset操作

Go语言系列（九）- Socket编程和RedisGo语言系列（九）- Socket编程和Redis



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
1package main

2

3import (

4    "fmt"

5

6    "github.com/garyburd/redigo/redis"

7)

8

9func main() {

10    c, err := redis.Dial("tcp", "localhost:6379")

11    if err != nil {

12        fmt.Println("conn redis failed,", err)

13        return

14    }

15

16    defer c.Close()

17    _, err = c.Do("HSet", "books", "abc", 100)

18    if err != nil {

19        fmt.Println(err)

20        return

21    }

22

23    r, err := redis.Int(c.Do("HGet", "books", "abc"))

24    if err != nil {

25        fmt.Println("get abc failed,", err)

26        return

27    }

28

29    fmt.Println(r)

30}

31

hset操作

Go语言系列（九）- Socket编程和RedisGo语言系列（九）- Socket编程和Redis



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
1package main

2

3import (

4    "fmt"

5

6    "github.com/garyburd/redigo/redis"

7)

8

9func main() {

10    c, err := redis.Dial("tcp", "localhost:6379")

11    if err != nil {

12        fmt.Println("conn redis failed,", err)

13        return

14    }

15

16    defer c.Close()

17    _, err = c.Do("lpush", "book_list", "abc", "ceg", 300)

18    if err != nil {

19        fmt.Println(err)

20        return

21    }

22

23    r, err := redis.String(c.Do("lpop", "book_list"))

24    if err != nil {

25        fmt.Println("get abc failed,", err)

26        return

27    }

28

29    fmt.Println(r)

30}

31

list队列操作

Go语言系列（九）- Socket编程和RedisGo语言系列（九）- Socket编程和Redis



1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
1package main

2

3import (

4    "fmt"

5

6    "github.com/garyburd/redigo/redis"

7)

8

9func main() {

10    c, err := redis.Dial("tcp", "localhost:6379")

11    if err != nil {

12        fmt.Println("conn redis failed,", err)

13        return

14    }

15

16    defer c.Close()

17    _, err = c.Do("expire", "abc", 10)

18    if err != nil {

19        fmt.Println(err)

20        return

21    }

22}

23

设置过期时间

 

Related posts:

  1. Linux的系统调用、网络连接状态、磁盘I/O；可疑行为监控/日志收集、SHELL命令执行流程
  2. 前端点滴（Node.js）（二）
  3. Linux Shell 编程
  4. 使用 shell 脚本对 Linux 系统和进程资源进行监控

给TA打赏
共{{data.count}}人
人已打赏
[db:标签]GO语言JavaScript分析命令域名安装指令数据服务器系统
安全技术

C++ 中 struct和class 的区别

2022-1-11 12:36:11

安全运维

史上最简单的 MySQL 教程（三十二）「子查询（下）」

2021-12-11 11:36:11

猜你喜欢

Linux Shell 编程

010
❯

解锁会员权限

开通会员

解锁海量优质VIP资源

立刻开通
个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索

  • 扫码打开当前页

返回顶部