# 接入Jito ShredStream
Shred作为Solana网络中数据传播的最小单元，以最快的速度在网络中以udp的形式传播。通过拼装解析Shred数据流可以使得交易者抢占先机。本文教你如何接入基于Jito的ShredStream，更详细的教程请参阅[Jito官方文档](https://docs.jito.wtf/lowlatencytxnfeed/)
## 申请授权pubkey
在此处填写jito提供的表单[注册授权pubkey](https://web.miniextensions.com/WV3gZjFwqNqITsMufIEp)，此账户中不应有任何的资金，提交时只需要提交pubkey即可。
## 防火墙放行Jito的IP
此处放行了jito所有区域的ip，可以在[此处](https://docs.jito.wtf/lowlatencytxnfeed/#firewall-configuration)查看。
```
ufw allow from 74.118.140.240
ufw allow from 202.8.8.174
ufw allow from 145.40.93.84
ufw allow from 145.40.93.41
ufw allow from 141.98.216.96
ufw allow from 64.130.48.56
ufw allow from 64.130.53.8
ufw allow from 64.130.53.57
ufw allow from 202.8.9.160
ufw allow from 202.8.9.19
```
## 下载配置jito-shredstream-proxy
查询自己的tvu端口
```
bash -c "$(curl -fsSL https://raw.githubusercontent.com/jito-labs/shredstream-proxy/master/scripts/get_tvu_port.sh)"
```
开启jito-shredstream数据流服务，默认接收到的shreds数据在本地udp 20000端口
```
git clone https://github.com/jito-labs/shredstream-proxy.git --recurse-submodules
RUST_LOG=info cargo run --release --bin jito-shredstream-proxy -- shredstream \
--block-engine-url https://frankfurt.mainnet.block-engine.jito.wtf \
--auth-keypair /root/xyz4g33hXuR84saNFe3tRgcu9NbB8AeqX5YMcLetMek.json \
--desired-regions amsterdam,frankfurt \
--dest-ip-ports 127.0.0.1:8001
```
* \--block-engine-url 为节点最近的 jito 区块引擎地址
* \--auth-keypair 为被授权的私钥
* \--desired-regions 为想要接收shreds的区域
* \--dest-ip-ports 为要绑定的接收shreds的IP和端口，即本地tvu端口
## 一个简单的解析示例
```
use pcap::{Capture, Device};
use solana_ledger::shred::Shred;
use std::error::Error;
fn main() -> Result<(), Box> {
// 获取网络设备列表
let devices = Device::list()?;
// 打印可用设备列表
// println!("可用网络设备:");
for (i, device) in devices.iter().enumerate() {
println!("{}. {}", i, device.name);
}
// 选择要监听的设备（这里假设使用第一个设备，你可以根据需要修改）
let device = &devices[0];
// 创建捕获器
let mut cap = Capture::from_device(device.name.as_str())?
.promisc(true)
.snaplen(65535)
.open()?;
// 设置过滤器只捕获UDP 20000端口的数据包
cap.filter("udp port 20000", true)?;
println!("开始监听 {} 上的UDP 20000端口...", device.name);
while let Ok(packet) = cap.next_packet() {
// UDP头部长度为8字节，我们需要跳过它
let payload = &packet.data[42..]; // 跳过以太网头(14字节) + IP头(20字节) + UDP头(8字节)
match Shred::new_from_serialized_shred(payload.to_vec()) {
Ok(shred) => {
println!("接收到Shred");
println!("ID: {:?}", shred.id());
println!("Slot: {}", shred.slot());
println!("Index: {}", shred.index());
println!("数据完整: {}", shred.data_complete());
if shred.is_data() {
println!("类型: 数据Shred");
let payload = shred.payload();
println!("payload长度: {}", payload.len());
} else {
println!("类型: 编码Shred");
}
println!("------------------------");
},
Err(e) => println!("解析Shred失败: {:?}", e),
}
}
Ok(())
}
```
```
cargo run
```
---
# Agent Instructions: Querying This Documentation
If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.
Perform an HTTP GET request on the current page URL with the `ask` query parameter:
```
GET https://chainbuff.gitbook.io/tutorials/solana/da-jian-ji-chu-she-shi/jie-ru-jito-shredstream.md?ask=
```
The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.
Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.