我有一个创建 web3 websocket 连接的节点 js 进程，如下所示:
web3 = new Web3('ws://localhost:7545')
当进程完成时(我向它发送一个 SIGTERM)，它不会退出，而是永远挂起，没有控制台输出。
我在 SIGINT 和 SIGTERM 上注册了一个监听器，以观察进程在 process._getActiveRequests() 和 process._getActiveHandles() 上有哪些处理，我看到了这个:
Socket {
connecting: false,
_hadError: false,
_handle:
TCP {
reading: true,
owner: [Circular],
onread: [Function: onread],
onconnection: null,
writeQueueSize: 0 },
<snip>
_peername: { address: '127.0.0.1', family: 'IPv4', port: 7545 },
<snip>
}
为了完整性，这里是监听信号的代码:
async function stop() {
console.log('Shutting down...')
if (process.env.DEBUG) console.log(process._getActiveHandles())
process.exit(0)
}
process.on('SIGTERM', async () => {
console.log('Received SIGTERM')
await stop()
})
process.on('SIGINT', async () => {
console.log('Received SIGINT')
await stop()
})
看起来 web3 正在打开一个套接字，这是有道理的，因为我从未告诉它关闭连接。通过文档和谷歌搜索，它看起来不像是 web3 对象的关闭或结束方法。
在上面的stop中手动关闭socket可以让进程成功退出:
web3.currentProvider.connection.close()
谁有更优雅或官方认可的解决方案？我觉得很有趣，你必须手动执行此操作而不是让对象在进程结束时自行销毁。其他客户端似乎会自动执行此操作，而不会明确告诉他们关闭连接。告诉您的节点进程创建的所有客户端无论如何在关闭时关闭它们的句柄/连接可能更清晰，但对我来说，这是出乎意料的。
最佳答案
It feels funny to me that you have to manually do this rather than have the object destroy itself on process end
这感觉很有趣，因为与异步相比，您可能接触过更多的同步编程。考虑下面的代码
fs = require('fs')
data = fs.readFileSync('file.txt', 'utf-8');
console.log("Read data", data)
当你在上面运行时，你会得到输出
$ node sync.js
Read data Hello World
这是一个同步代码。现在考虑相同的异步版本
fs = require('fs')
data = fs.readFile('file.txt', 'utf-8', function(err, data) {
console.log("Got data back from file", data)
});
console.log("Read data", data);
当你运行时你会得到下面的输出
$ node async.js
Read data undefined
Got data back from file Hello World
现在如果你以同步程序员的身份思考，程序应该在最后一个console.log("Read data", data);处结束，但是你得到的是之后打印的另一条语句。现在觉得好笑吗？让我们在流程中添加一个退出语句
fs = require('fs')
data = fs.readFile('file.txt', 'utf-8', function(err, data) {
console.log("Got data back from file", data)
});
console.log("Read data", data);
process.exit(0)
现在，当您运行该程序时，它会在最后一条语句处结束。
$ node async.js
Read data undefined
但实际上并没有读取文件。为什么？因为你从来没有给 JavaScript 引擎时间来执行挂起的回调。理想情况下，当没有剩余工作要做时(没有挂起的回调、函数调用等...)，进程会自动完成。这就是异步世界的工作方式。您应该研究一些不错的 SO 线程和文章
https://medium.freecodecamp.org/walking-inside-nodejs-event-loop-85caeca391a9
https://nodejs.org/en/docs/guides/event-loop-timers-and-nexttick/
Why doesn't my Node.js process terminate once all listeners have been removed?
How does a node.js process know when to stop?
因此在异步世界中，您需要告诉进程退出，或者当没有未决任务时它会自动退出(您知道如何检查 - process._getActiveRequests() 和 process._getActiveHandles())
关于javascript - web3 websocket连接阻止节点进程退出，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/50632114/
我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作)，这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以
我使用的是Firefox版本36.0.1和Selenium-Webdrivergem版本2.45.0。我能够创建Firefox实例，但无法使用脚本继续进行进一步的操作无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)错误。有人能帮帮我吗？ 最佳答案 我遇到了同样的问题。降级到firefoxv33后一切正常。您可以找到旧版本here 关于ruby-无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)，我们在StackOverflow上找到一个类
require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器，我做错了什么？ 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame
我遇到了一个非常奇怪的问题，我很难解决。在我看来，我有一个与data-remote="true"和data-method="delete"的链接。当我单击该链接时，我可以看到对我的Rails服务器的DELETE请求。返回的JS代码会更改此链接的属性，其中包括href和data-method。再次单击此链接后，我的服务器收到了对新href的请求，但使用的是旧的data-method，即使我已将其从DELETE到POST(它仍然发送一个DELETE请求)。但是，如果我刷新页面，HTML与"new"HTML相同(随返回的JS发生变化)，但它实际上发送了正确的请求类型。这就是这个问题令我困惑的
考虑一下:现在这些情况:#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2我需要用其他字符串输出URL。我如何保证＆符号不会被转义？由于我无法控制的原因，我无法发送&。求助!把我的头发拉到这里:\编辑:为了澄清，我实际上有一个像这样的数组:@images=[{:id=>"fooid",:url=>"http://
我正在使用Ruby/Mechanize编写一个“自动填写表格”应用程序。它几乎可以工作。我可以使用精彩CharlesWeb代理以查看服务器和我的Firefox浏览器之间的交换。现在我想使用Charles查看服务器和我的应用程序之间的交换。Charles在端口8888上代理。假设服务器位于https://my.host.com。.一件不起作用的事情是:@agent||=Mechanize.newdo|agent|agent.set_proxy("my.host.com",8888)end这会导致Net::HTTP::Persistent::Error:...lib/net/http/pe
我有一个super简单的脚本，它几乎包含了FayeWebSocketGitHub页面上用于处理关闭连接的内容:ws=Faye::WebSocket::Client.new(url,nil,:headers=>headers)ws.on:opendo|event|p[:open]#sendpingcommand#sendtestcommand#ws.send({command:'test'}.to_json)endws.on:messagedo|event|#hereistheentrypointfordatacomingfromtheserver.pJSON.parse(event.d
我有一个ruby脚本可以打开与Apple推送服务器的连接并发送所有待处理的通知。我看不出任何原因，但当Apple断开我的脚本时，我遇到了管道损坏错误。我已经编写了我的脚本来适应这种情况，但我宁愿只是找出它发生的原因，这样我就可以在第一时间避免它。它不会始终根据特定通知断开连接。它不会以特定的字节传输大小断开连接。一切似乎都是零星的。您可以在单个连接上发送的数据传输或有效负载计数是否有某些限制？看到人们的解决方案始终保持一个连接打开，我认为这不是问题所在。我看到连接在3次通知后断开，我看到它在14次通知后断开。我从未见过它能超过14点。有没有人遇到过这种类型的问题？如何处理？
我的意思是之前建立的那个DB=Sequel.sqlite('my_blog.db')或DB=Sequel.connect('postgres://user:password@localhost/my_db')或DB=Sequel.postgres('my_db',:user=>'user',:password=>'password',:host=>'localhost')等等。Sequel::Database类没有名为“disconnect”的公共(public)实例方法，尽管它有一个“connect”。也许有人已经遇到过这个问题。我将不胜感激。 最佳答案
我有一个遗留数据库，我正在努力让ActiveRecord使用它。我遇到了连接表的问题。我有以下内容:classTvShow然后我有一个名为tvshowlinkepisode的表，它有2个字段:idShow、idEpisode所以我有2个表和它们之间的连接(多对多关系)，但是连接使用非标准外键。我的第一个想法是创建一个名为TvShowEpisodeLink的模型，但没有主键。我的想法是，由于外键是非标准的，我可以使用set_foreign_key并进行一些控制。最后，我想说一些类似TvShow.find(:last).episodes或Episode.find(:last).tv_sho