MongoDB 事件插件

┌──────────────┐   事件投递    ┌────────────┐    数据写入    ┌──────────┐    HTTP 查询   ┌──────────┐
│ TRON 全节点  │ ──────────▶ │  事件插件  │ ──────────▶ │ MongoDB  │ ◀───────── │ 查询服务 │
│ (java-tron)  │  (进程内)   │  (.jar 包) │             │  数据库  │   数据查询  │ (选配项) │
└──────────────┘             └────────────┘             └──────────┘            └────┬─────┘
                                                                                     │ HTTP 响应
                                                                                     ▼
                                                                              ┌──────────────┐
                                                                              │  业务系统    │
                                                                              └──────────────┘

git clone https://github.com/tronprotocol/event-plugin.git
cd event-plugin
./gradlew build

# 下载并解压归档包 — 以 7.0.16 稳定版为例
MONGODB_VERSION=7.0.16
cd /home/java-tron
curl -O https://fastdl.mongodb.org/linux/mongodb-linux-x86_64-${MONGODB_VERSION}.tgz
tar zxvf mongodb-linux-x86_64-${MONGODB_VERSION}.tgz
mv mongodb-linux-x86_64-${MONGODB_VERSION} mongodb

# 将二进制路径配置到环境变量中
export MONGOPATH=/home/java-tron/mongodb/
export PATH=$PATH:$MONGOPATH/bin

# 准备数据目录及日志文件存放路径
mkdir -p /home/java-tron/mongodb/{log,data}
touch /home/java-tron/mongodb/log/mongodb.log

dbpath=/home/java-tron/mongodb/data
logpath=/home/java-tron/mongodb/log/mongodb.log
port=27017
logappend=true
fork=true
bind_ip=0.0.0.0
auth=true
wiredTigerCacheSizeGB=2

# 启动 MongoDB 服务
mongod --config ./mgdb.conf &

# 进入控制台
mongo
# 进入 admin 库创建超级管理员账户
> use admin
> db.createUser({user:"root", pwd:"<Your-Password1>", roles:[{role:"root", db:"admin"}]})

# 认证超级管理员登录，并创建 eventlog 数据库及其专属的 Owner 账户
> db.auth("root", "<Your-Password1>")
> use eventlog
> db.createUser({user:"tron", pwd:"<Your-Password2>", roles:[{role:"dbOwner", db:"eventlog"}]})

event.subscribe = {
  version = 1            // 1 表示启用 V2.0 事件框架（支持历史回填）；0 表示启用 V1.0 框架（默认值）
  startSyncBlockNum = 0  // 仅在 V2.0 框架下有效——具体配置参见下方说明

  native = {
    useNativeQueue = false   // 必须配置为 false，否则事件将走 ZeroMQ 而非外部插件
    bindport = 5555
    sendqueuelength = 1000
  }

  path = "/deploy/fullnode/event-plugin/build/plugins/plugin-mongodb-1.0.0.zip" // 插件包的绝对路径
  server = "127.0.0.1:27017" // MongoDB 服务连接地址
  dbconfig = "eventlog|tron|<Your-Password2>"   // 格式为：数据库名|鉴权用户名|鉴权密码
  contractParse = true

  topics = [
    { triggerName = "block",         enable = true, topic = "block" },
    { triggerName = "transaction",   enable = true, topic = "transaction" },
    { triggerName = "contractevent", enable = true, topic = "contractevent" },
    { triggerName = "contractlog",   enable = true, topic = "contractlog" }
  ]

  filter = {
    fromblock = ""             // "", "earliest", 或特定的区块高度
    toblock = ""               // "", "latest", 或特定的区块高度
    contractAddress = [ "" ]   // 合约地址过滤；保留为空时匹配所有合约
    contractTopic = [ "" ]     // 事件哈希过滤；保留为空时匹配所有合约事件
  }
}

java -jar FullNode.jar -c config.conf --es

tail -f logs/tron.log | grep -i eventplugin

[o.t.c.l.EventPluginLoader] '/path/to/plugin-mongodb-1.0.0.zip' loaded

mongo <mongo-host>:27017
> use eventlog
> db.auth("tron", "<Your-Password2>")
> show collections          # 应该包含：block, transaction, contractevent, contractlog 等集合
> db.block.find().limit(1)  # 查询最新写入的一条区块事件记录

git clone https://github.com/tronprotocol/tron-eventquery.git
cd tron-eventquery

# 安装并配置好 Maven 3.9+ 环境
mvn --version
mvn package

mongo.host=<mongo-ip>
mongo.port=27017
mongo.dbname=eventlog
mongo.username=tron
mongo.password=<Your-Password2>
mongo.connectionsPerHost=8
mongo.threadsAllowedToBlockForConnectionMultiplier=4

sh deploy.sh
sh insertIndex.sh

nohup java -jar -Dserver.port=8081 target/troneventquery-1.0.0-SNAPSHOT.jar 2>&1 &