Go-Ethereum

Whisper：當 geth 關閉或 shh.newMessageFilter() 未啟動時，我們如何列印接收到的實際儲存在記憶體中的消息？

  • June 27, 2018

Whisper 協議在其使用方面沒有得到很好的記錄。我相信這個問題將幫助其他可能面臨類似問題的使用者。

每條發送的消息都有以秒為單位的生存時間 ( ttl)，這是由發送者定義的。有關更多詳細資訊，請參閱Whisper v5 RPC API => shh_post。Whisper Protocol將收到的消息保留在記憶體中，直到消息的time-to-live時間結束、geth關閉或未shh.newMessageFilter()啟動。

**=>**我們如何訪問和列印那些實際儲存在記憶體中的接收到的消息？

Whisper v5 RPC API：

shh_getFilterMessages

檢索與過濾條件匹配並在上次呼叫此函式到現在之間收到的消息。

  • 但是沒有getFilterMessages()最新的方法shh。請看。

關於這個解決方案；geth重啟後我們可以使用相同的密鑰對。但是之後的問題geth是重新啟動，然後當我們執行時shh.newMessageFilter()；它不會檢索/返回geth關閉時發送的任何消息。

**$$ Q $$**我們如何獲取/過濾geth關閉或未shh.newMessageFilter()啟動時發送的消息？當我們執行時web3.shh.newMessageFilter()，它僅在開始執行後立即檢索/過濾消息，並且在開始執行之前不過濾/列印任何消息。

範例場景：

**=>**在我關閉的接收節點上geth，從發送節點，我已經向接收節點發送了多條消息。後來，當我geth在接收節點上重新打開時，shh.info.memory驗證記憶體中是否有接收到的消息，但我無法使用web3.shh.newMessageFilter().

> shh.info.memory
780

這是一些日誌：

創建web3.shh.newMessageFilter()：

> kId=shh.addPrivateKey('0x8de0b39f3a4a109f27bb06a92dab680d58e8f029eaca61da6be7115981a2ed11')
"439bfd6aa63a81b404ba20e4fc250e11c326d72ad9943c72dc445f476638989d"

> filter=web3.shh.newMessageFilter(
...         {privateKeyID:kId},
...         function(err, res) {console.log(web3.toUtf8(res.payload))});
{
 callbacks: [function(err, res)],
 filterId: "a0b4194651c9143d977c2fa4848ab681b414720364461b4096fb17588d84ae78",
 formatter: null,
 getLogsCallbacks: [],
 implementation: {
   getLogs: function(),
   newFilter: function(),
   poll: function(),
   uninstallFilter: function()
 },
 options: {
   privateKeyID: "439bfd6aa63a81b404ba20e4fc250e11c326d72ad9943c72dc445f476638989d"
 },
 pollFilters: [],
 requestManager: {
   polls: {
     82f08d2d7fe974a69acdadcfac39f788575d337eed9577969b617ae28462e597: {
       data: {...},
       id: "82f08d2d7fe974a69acdadcfac39f788575d337eed9577969b617ae28462e597",
       callback: function(error, messages),
       uninstall: function()
     },
     a0b4194651c9143d977c2fa4848ab681b414720364461b4096fb17588d84ae78: {
       data: {...},
       id: "a0b4194651c9143d977c2fa4848ab681b414720364461b4096fb17588d84ae78",
       callback: function(error, messages),
       uninstall: function()
     }
   },
   provider: {
     newAccount: function(),
     openWallet: function(),
     send: function github.com/ethereum/go-ethereum/console.(*bridge).Send-fm(),
     sendAsync: function github.com/ethereum/go-ethereum/console.(*bridge).Send-fm(),
     sign: function(),
     unlockAccount: function()
   },
   timeout: {},
   poll: function(),
   reset: function(keepIsSyncing),
   send: function(data),
   sendAsync: function(data, callback),
   sendBatch: function(data, callback),
   setProvider: function(p),
   startPolling: function(data, pollId, callback, uninstall),
   stopPolling: function(pollId)
 },
 get: function(callback),
 stopWatching: function(callback),
 watch: function(callback)
}

我可以shh_getFilterMessages在下面看到，filter.requestManager.polls但我不能稱之為。

> filter.requestManager.polls
{
 82f08d2d7fe974a69acdadcfac39f788575d337eed9577969b617ae28462e597: {
   data: {
     method: "shh_getFilterMessages",
     params: ["82f08d2d7fe974a69acdadcfac39f788575d337eed9577969b617ae28462e597"]
   },
   id: "82f08d2d7fe974a69acdadcfac39f788575d337eed9577969b617ae28462e597",
   callback: function(error, messages),
   uninstall: function()
 },
 a0b4194651c9143d977c2fa4848ab681b414720364461b4096fb17588d84ae78: {
   data: {
     method: "shh_getFilterMessages",
     params: ["a0b4194651c9143d977c2fa4848ab681b414720364461b4096fb17588d84ae78"]
   },
   id: "a0b4194651c9143d977c2fa4848ab681b414720364461b4096fb17588d84ae78",
   callback: function(error, messages),
   uninstall: function()
 }
}

> a.requestManager.polls.82f08d2d7fe974a69acdadcfac39f788575d337eed9577969b617ae28462e597
(anonymous): Line 1:23 Unexpected token ILLEGAL

web3.py方法：

from web3 import Web3, HTTPProvider
web3 = Web3(HTTPProvider('http://localhost:8545'))
from web3.shh import Shh
Shh.attach(web3, "shh")

import time
print(web3.shh.info)

keyPair = web3.shh.newKeyPair();

kId = web3.shh.addPrivateKey(keyPair)
print(web3.shh.hasKeyPair(kId))
print('PubKey: ' + web3.shh.getPublicKey(kId))

#Message sent before filter is assigned
web3.shh.post({
 'pubKey': web3.shh.getPublicKey(kId),
 'topic': '0x07678231',
 'powTarget': 2.01,
 'powTime': 2,
 'ttl': 10,
 'payload': web3.toHex(text="test message :)")

});
time.sleep(1)    

received_messages = [];
myFilter = web3.shh.newMessageFilter({'topic': '0x07678231',
                                     'privateKeyID': kId
                                     });
myFilter.poll_interval = 600;

print(myFilter.filter_id)
received_messages = myFilter.get_all_entries() # Error occurs!!
print(received_messages)

我遇到的錯誤：

 File "/home/alper/eBlocBroker/venv/lib/python3.5/site-packages/web3/utils/filters.py", line 191, in get_all_entries
   raise NotImplementedError()
NotImplementedError

最新Web3.js的沒有web3.shh.getMessages()；但web3.py有它。所以我能夠使用web3.py.

Shh.getMessages(self, filter_id)

=> 檢索與過濾條件匹配並在上次呼叫此函式到現在之間收到的消息。

=> 返回自上次呼叫以來的所有新消息

首先你必須保存keyPair和filter-id：

from web3 import Web3, HTTPProvider
web3 = Web3(HTTPProvider('http://localhost:8545'))
from web3.shh import Shh
Shh.attach(web3, "shh")
import time

keyPair =  web3.shh.newKeyPair();
kId     = web3.shh.addPrivateKey(keyPair)
myFilter = web3.shh.newMessageFilter({'topic': '0x07678231',
                                     'privateKeyID': kId
                                     });
myFilter.poll_interval = 600;
print('keyPair: '  + keyPair)
print('FilterID: ' + myFilter.filter_id)

輸出：

keyPair: 0xa82ff6abcf75393084edb06d100e53268c5e118884d59282ef9d3396c8537011
FilterID: 35e2f4c4451fb36da13260c67fe57bdff1f2aeea2bdd346611eef61903c19aaa

稍後做以下操作；這將列印記憶體中存在的消息。：

from web3 import Web3, HTTPProvider
web3 = Web3(HTTPProvider('http://localhost:8545'))
from web3.shh import Shh
Shh.attach(web3, "shh")
import time
print(web3.shh.info)

keyPair =  '0xa82ff6abcf75393084edb06d100e53268c5e118884d59282ef9d3396c8537011'; # obtained from web3.shh.newKeyPair();    
kId = web3.shh.addPrivateKey(keyPair)
print(web3.shh.hasKeyPair(kId))
print('PubKey: ' + web3.shh.getPublicKey(kId))

# Message is sent before the filter is activated
web3.shh.post({
 'pubKey': web3.shh.getPublicKey(kId),
 'topic': '0x07678231',
 'powTarget': 2.01,
 'powTime': 2,
 'ttl': 10,
 'payload': web3.toHex(text="test message :)")

});
time.sleep(1)

filterID = '35e2f4c4451fb36da13260c67fe57bdff1f2aeea2bdd346611eef61903c19aaa' #Filter-id is obtained from previous session.
retreived_messages = web3.shh.getMessages(filterID) 

for i in range(0, len(retreived_messages)):
   print(retreived_messages[i]['payload'].decode("utf-8"))
   print(retreived_messages[i])

輸出：

test message :)
{'padding': HexBytes('0xcd6e2ee5fb8d7c4b7e296397c2e9d6d2ba9563c003295004afe488dffc384833b8f5ada10a01dd08f16bf6e72a1f6a6ab45ffa3a1a2e23e2a5853b7978d438e306660e22b3edf93359c290dcf5669072aba1c19ab9012d8904f80f7daa256d0d796f4ae096b7ece2c3a34e2f19f5162916bd4537492a137e84d2b717a3b2a91cf4f6291dd5c26d17cdc7df94ddfdedeaad2b216925e9404c8f645cee9cf338957c374e4d6770f27db8624689b7ba4604b3f05ba7d4fa06560a165860dbd1b54562bde7e96686c96aee7a9ad45e2669a05323eec89f5ea23dcda8308cb494d774a1d28b0f8e4058c410326a8fdf'), 
'topic': HexBytes('0x07678231'), 
'payload': HexBytes('0x74657374206d657373616765203a293e3e'),
'recipientPublicKey': HexBytes('0x04d96278caa49aff29d76399001a43a9a8005da21c6853d20d6af11d61df8a2a25de0fe79a1099bd4b915445d94cbd448b2fe548fb53fed5d887291f35de0f44c9'),
'timestamp': 1530126289, 
'ttl': 10, 
'pow': 8.402051282051282, 
'hash': HexBytes('0x58240972265ea90d3cd8af3d71a8eb4663ae5bfccd00f3e2fb100c5072798017')}

引用自：https://ethereum.stackexchange.com/questions/51859

相關問答

Solidity

rinkeby infura 使用布朗尼的 gas 資金不足錯誤

  • May 24, 2022
檢視問答
Solidity

無法在 Windows 上安裝 web3.py：無法打開包含文件：“io.h”：

  • April 26, 2022
檢視問答
Go-Ethereum

web3.py geth txpool 幫助

  • April 9, 2022
檢視問答
Solidity

無法導入 web3

  • March 19, 2022
檢視問答
Go-Ethereum

如何使 Docker 容器與本地主機上的 geth.ipc 通信

  • March 6, 2022
檢視問答
Solidity

當我輸入 FALSE 時……我收到了錯誤的輸出，當我輸入 TRUE 時……我收到了真正的輸出，但是當我輸入 NO 時……我仍然收到了 True 輸出

  • February 17, 2022
檢視問答