如何使用shh.subscribe

Question

我想使用web3-shh功能。我使用了来自readthedocs(web3-shh)的例子。除了订阅操作之外，一切都正常工作。它会引发以下错误：

UnhandledPromiseRejectionWarning: Error: Subscriptions are not supported with the HttpProvider.

知道怎么处理这事吗？我使用的测试程序是

import Web3            from 'web3';
const uri = process.env.ETH_NODE_URI || 'http://localhost:8545';
var web3 = new Web3(new Web3.providers.HttpProvider(uri));

var identities = [];

Promise.all([
web3.shh.newSymKey().then((id) => {identities.push(id);}),
web3.shh.newKeyPair().then((id) => {identities.push(id);})
]).then(() => {
var subscription = web3.shh.subscribe('messages', {
    symKeyID: identities[0],
    topics: ['0xffaadd11']
}).on('data', console.log);
}).then(() => {
web3.shh.post({
    symKeyID: identities[0], // encrypts using the sym key ID                                                  
    sig: identities[1], // signs the message using the keyPair ID                                              
    topic: '0xffaadd11',
    payload: '0xffffffdddddd1122'
}).then(h => console.log(`Message with hash ${h} was successfuly sent`))
.catch(err => console.log("Error: ", err));
});

我希望就如何处理这个问题提出任何建议。文档中的完整示例也是一个好主意。

Answer 1

正如Sanjay上面所指出的，您需要websocket才能执行其实时通知传入消息的功能。

下面是一个如何创建Websocket (使用ethjs，但web3.js类似) https://github.com/invisible-college/democracy/blob/master/packages/whisper/src/whisper.js#L23的示例

如果您运行您自己的语音节点，如geth或状态-go实现(我鼓励您这样做，因为其他人的私语节点将能够窥探您的键盘)，您应该使用--wsorigins="mychat"标志启动它，只要您在客户端中创建websocket提供程序时选择相同的值，"mychat“就可以是任何内容。