有时候解析包出错

[fwhezfwhez]

有时候解析包出错

[fwhezfwhez]

1. 是最新的master分支吗。

2. tcpx.FirstBlockOf(conn) 这个语句中的conn，有没有同时被多个地方Read。

buf, e:= tcpx.FirstBlockOf(conn)

这里的e可能有错误，贴一下

[pickalex]

fwhezfwhez 你好
我是前天go get 的包,应该是最新的

只有一个地方读取
go Recv(conn,tasks)

buf, e:=tcpx.FirstBlockOf(conn) 这里没有错误
出错的是下面这句
bufbody,err := tcpx.BodyBytesOf(buf)
if err!=nil{
fmt.Println(err.Error())
return
}

报错信息: stream lenth should be bigger than 12
就像上面说的 这个错误信息10次会出现7-8次,2,3次能正常读取

[fwhezfwhez]

buf, e:=tcpx.FirstBlockOf(conn)

在这里打印一下buf

[pickalex]

正确时候的值 buf: [24625/27264]0xc00006ca80

错误的值 buf: [10/16]0xc000090620

[fwhezfwhez]

@pickalex 你贴的buf，我看不太懂，buf应该是长这样的 [0 0 1 122 22 23 ....] 这样的。

[fwhezfwhez]

我暂时看不出问题，不过针对你的场景，进行了重演， 你可以参考一下，看看哪里使用不当了

https://github.com/fwhezfwhez/tcpx/blob/pack%2338/issue_38/server.go
https://github.com/fwhezfwhez/tcpx/blob/pack%2338/issue_38/client.go

该分支为pack#38,如下所示，并发十万次，没有复现问题。

package main

import "github.com/fwhezfwhez/tcpx"

func main() {
	srv := tcpx.NewTcpX(tcpx.JsonMarshaller{})

	srv.AddHandler(5, func(c *tcpx.Context) {

		type Data struct {
			Table string        `json:"table"`
			Sql   string        `json:"sql"`
			Count string        `json:"count"`
			Args  []interface{} `json:"args"`
			Ids   []string      `json:"ids"`
		}

		var data = Data{
			Table: "tcpx",
			Sql:   "select * from user_info",
			Count: "5",
			Args:  []interface{}{"1", "2"},
			Ids:   []string{"1", "10"},
		}
		c.JSON(6, data)
	})

	if e := srv.ListenAndServe("tcp", ":8080"); e != nil {
		panic(e)
	}
}

package main

import (
	"encoding/json"
	"fmt"
	"net"
	"sync"
	"tcpx"
)

func main() {
	conn, e := net.Dial("tcp", "localhost:8080")
	if e != nil {
		fmt.Println(e.Error())
		return
	}
	go recv(conn)

	buf := tcpx.PackStuff(5)

	wg := sync.WaitGroup{}

	var jobNum = 100000
	wg.Add(jobNum)

	for i := 0; i < jobNum; i++ {
		go func() {
			defer wg.Done()
			conn.Write(buf)
		}()
	}
	wg.Wait()
	fmt.Printf("成功执行完%d个任务\n", jobNum)
}

func recv(conn net.Conn) {
	for {
		buf, e := tcpx.FirstBlockOf(conn)
		if e != nil {
			panic(e)
		}

		var rs map[string]interface{}

		bodyBuf, e := tcpx.BodyBytesOf(buf)
		if e != nil {
			panic(e)
		}

		if e := json.Unmarshal(bodyBuf, &rs); e != nil {
			panic(e)
		}
		fmt.Println(tcpx.Debug(rs))
	}
}

[pickalex]

hello ,fwhezfwhez 我看看能不能写个重现的demo，我用了第三方库sqlbuilder 构造sql 和 args，等我下

[pickalex]

fwhezfwhez ,不好意思这几天其他事情耽误了 ,因为我的代码是关联了数据库,我尝试手动弄一个假的数据集又都是正确的结果,
上面buf 打印的结构是这样的 :[0 0 0 6 0 0 0 2 0 0]
或者你得空的时候加我QQ,我们再详细讨论下 454673018 (天明),祝生活愉快

[pickalex]

晕,上面QQ号打错了,464573018

[fwhezfwhez]

已私聊解决，客户端Conn双协程读取引起的。