Wireshark网络分析之追踪TiDB官方Bug

站长

2022年12月17日 21:39 · 阅读数 60

问题描述

在我们的小程序首页，用户点击不同的区域，因不同的区域是有不同的内容，但诡异的是返回了同样的信息。

技术实现，包括前后端的逻辑都是非常简单的：后端的不同区域分配的id值不同，前端传入参数带上这个id，以便得到不同的结果。

发生问题之后，我们将注意力集中到后端具体的请求接口，最终的逻辑就是一句SQL语句

SELECT * FROM tbl_challenge WHERE (id=?)

这条语句真的是简单的不能再简单了：根据id，返回不同的记录

明明输入的id=1和id=2，但结果都返回了id=1的记录。

奇哉怪哉。

问题分析

解决该问题之前，首先要做的就是复现该问题。

我们写了一个单元测试，立马复现，代码如下：

func TestTiDBQueryId(t *testing.T) {
   t.Run("test query id", func(t *testing.T) {
      var info1 = &TblCropInfo{}
      selectSql := `SELECT * FROM tbl_crop_info WHERE (id=?)`
      err := libs.GetMysqlDb(DressUpDb).Raw(selectSql, 2).QueryRow(&info1)
      assert.Nil(t, err)

      var info2 = &TblCropInfo{}
      selectSql = `SELECT * FROM tbl_crop_info WHERE (id=?)`
      err = libs.GetMysqlDb(DressUpDb).Raw(selectSql, 4).QueryRow(&info2)
      assert.Nil(t, err)
      assert.Equal(t, info1, info2)
   })
}

结果返回的都是id=2的数据

那么好，既然复现了。我们需要确定这个问题到底是我们client的问题，还是TiDB服务器的问题。

考虑到TiDB已经被广泛应用，我们首先怀疑自己的代码或者依赖的包有问题。

因为业务逻辑非常简单，很快排除了代码的问题。

那如何确定第三方client包的问题？

第一种方法就是运行代码，进行Debug，一步一步追踪代码的逻辑。

优点是「代码之下，毫无秘密」，缺点是代码较为复杂、层层叠叠，很容易迷失在调用的过程中。

不过幸好，我们还好第二种方法。

第二种方法就是直接抓包。看看我们发出去的请求包中的id值是否为想要赋予的值。

最终确定通过wireshark抓包的方式进行问题的追踪。(因为我自己也比较拿手）

抓包分析

我们的问题在于：代码中给定不同的id，却返回了同一条数据记录。

实验的目的是验证：我们的client发送给TiDB server两个请求中id值是否相等。

为此，我们将这一任务分成两部分：首先抓到请求包，然后对抓包的包进行分析。

进行抓包

根据目的IP，确定网卡接口

为此，我们需要route命令，本质上是查看路由表。根据目的ip，路由表会告诉我们发出信息会经过本机的哪一个网卡接口.

比如我们想要抓取请求百度的包，那它经过哪个网卡呢？

🐂🍺  ~  route -n get www.baidu.com

route to: 110.242.68.4
destination: default
mask: default
gateway: 192.168.10.1
interface: en0
flags: <UP,GATEWAY,DONE,STATIC,PRCLONING>
recvpipe sendpipe ssthresh rtt,msec rttvar hopcount mtu expire
0 0 0 0 0 0 1500 0

没错，如上所展示的，经过en0。那么由此可以确定，wireshark主界面应该选择en0接口，抓取到百度的包。

确定送请求到TiDB server的网卡信息，类似上面百度的例子，只需要我们将TiDB server的ip地址替换掉www.baidu.com即可。

进行抓包，然后运行代码，得到抓包文件。

// 代码类似如下
func TestTiDBQueryId(t *testing.T) {
    t.Run("test query id", func(t *testing.T) {
    var info1 = &TblCropInfo{}
    selectSql := `SELECT * FROM tbl_challenge WHERE (id=?)`
    err := libs.GetMysqlDb(DressUpDb).Raw(selectSql, 2).QueryRow(&info1)
    assert.Nil(t, err)

    var info2 = &TblCropInfo{}
    selectSql = `SELECT * FROM tbl_challenge WHERE (id=?)`
    err = libs.GetMysqlDb(DressUpDb).Raw(selectSql, 4).QueryRow(&info2)
    assert.Nil(t, err)
    assert.Equal(t, info1, info2)
    })
}