为什么我的“newPendingTransactions”geth 订阅没有收到任何事件？

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《为什么我的“newPendingTransactions”geth 订阅没有收到任何事件？》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

我面临以下挑战。我尝试通过 websocket 订阅“newpendingtransactions”。我可以成功连接到 websocket。连接后，我期望有一个新传入的待处理事务流，我可以将其读出并将其传播到某个通道（chan json.rawmessage）。

...

c, httpresponse, err := websocket.defaultdialer.dial(u.string(), req.header)

...

for {
        messagetype, message, err := c.readmessage()
        if err != nil {
            log.println("error:", err)
            os.exit(1)
            return
        }
        _, _ = message, messagetype
        // s.out is the outgoing chan json.rawmessage
        s.out <- message
}

...

遗憾的是我没有收到任何消息（待发送）..只有一条关于关闭整个构造的消息。当我直接在控制台中使用“txpool.status”检查我的节点时，我可以看到一直有新的待处理交易传入。他们只是不想传播到我的 websocket 连接。这里有人可以帮助我吗？也许我缺少启动 geth 节点本身的参数？

这是我启动 geth 节点的方法：

geth --http.api eth,web3,debug,txpool,net,shh,db,admin,debug --http --ws --ws.api eth,web3,debug,txpool,net,shh,db,admin,debug  --ws.origins localhost --gcmode full --http.port=8545 --maxpeers 120

这是我的“admin.nodeinfo”：

Geth/v1.10.16-stable-20356e57/linux-amd64/go1.17.5

正确答案

我发现我做错了什么：

这与任何被遗忘的 geth 参数无关，甚至“newpendingtransactions”已正确传播。

我使用另一个名为“wscat”的工具测试了 websocket 连接，并通过控制台发送了必要的 rpc（产生了 tx 哈希流！）

{"id": 1, "method": "eth_subscribe", "params": ["newpendingtransactions"]}

它告诉我错误一定是关于 golang 代码本身..

for循环中的最后一行

s.out <- message

正在将消息发送到无缓冲的通道中。为了使其工作，其他一些 go 例程必须消耗另一侧的通道消息。

使用这样的缓冲通道也有帮助：

s.Out = make(chan Message, 1000)

...所以至少会发送 1000 条消息

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~