MongoDB 事件插件

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

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

# 安装 MongoDB 二进制归档包所需的系统依赖
sudo apt-get update
sudo apt-get install -y curl libcurl4 libgssapi-krb5-2 libldap-2.5-0 libwrap0 \
  libsasl2-2 libsasl2-modules libsasl2-modules-gssapi-mit openssl liblzma5

# 下载并校验归档包 — 以 Ubuntu 22.04 x86_64 上的 7.0.24 为例
MONGODB_VERSION=7.0.24
MONGODB_PLATFORM=ubuntu2204
MONGODB_ARCHIVE=mongodb-linux-x86_64-${MONGODB_PLATFORM}-${MONGODB_VERSION}.tgz
cd /home/java-tron
curl -O "https://fastdl.mongodb.org/linux/${MONGODB_ARCHIVE}"
curl -O "https://fastdl.mongodb.org/linux/${MONGODB_ARCHIVE}.sha256"
sha256sum -c "${MONGODB_ARCHIVE}.sha256"
tar zxvf "${MONGODB_ARCHIVE}"
mv "mongodb-linux-x86_64-${MONGODB_PLATFORM}-${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

storage:
  dbPath: /home/java-tron/mongodb/data
  wiredTiger:
    engineConfig:
      cacheSizeGB: 2
systemLog:
  destination: file
  path: /home/java-tron/mongodb/log/mongodb.log
  logAppend: true
net:
  port: 27017
  bindIp: 127.0.0.1
processManagement:
  fork: true
security:
  authorization: enabled

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

# 进入控制台
mongosh
# 进入 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 = {
  enable = true         // 启用事件订阅
  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-3.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

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

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

mongosh --host 127.0.0.1 --port 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+ 环境，并安装 deploy.sh 所需的 bc
sudo apt-get update
sudo apt-get install -y bc
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

mongodb='mongo '$mongoIp':'$mongoPort

mongodb="mongosh --host ${mongoIp} --port ${mongoPort}"

sh deploy.sh
sh insertIndex.sh

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