⚡ بدء سريع (shreds خام)

import dgram from 'node:dgram';

const PORT = parseInt(process.env.SHREDSTREAM_PORT || '8080');
const sock = dgram.createSocket('udp4');

sock.on('message', (shred) => {
  // وحدات بايت shred سولانا الخام — مرّرها إلى أداة فك التجميع / فك الترميز لديك.
  console.log(`shred: ${shred.length} bytes`);
});

sock.bind(PORT, '0.0.0.0');

import os, socket
PORT = int(os.environ.get("SHREDSTREAM_PORT", 8080))
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sock.bind(("0.0.0.0", PORT))
while True:
    shred, _ = sock.recvfrom(65535)
    # وحدات بايت shred سولانا الخام — مرّرها إلى أداة فك التجميع / فك الترميز لديك.
    print(f"shred: {len(shred)} bytes")

use std::net::UdpSocket;

fn main() -> std::io::Result<()> {
    let port: u16 = std::env::var("SHREDSTREAM_PORT")
        .ok().and_then(|v| v.parse().ok()).unwrap_or(8080);
    let sock = UdpSocket::bind(("0.0.0.0", port))?;
    let mut buf = [0u8; 65535];
    loop {
        let (n, _) = sock.recv_from(&mut buf)?;
        // وحدات بايت shred سولانا الخام — مرّرها إلى أداة فك التجميع / فك الترميز لديك.
        println!("shred: {} bytes", n);
    }
}

package main

import (
    "fmt"
    "net"
    "os"
    "strconv"
)

func main() {
    port, _ := strconv.Atoi(os.Getenv("SHREDSTREAM_PORT"))
    if port == 0 {
        port = 8080
    }
    sock, err := net.ListenUDP("udp", &net.UDPAddr{IP: net.IPv4zero, Port: port})
    if err != nil {
        panic(err)
    }
    defer sock.Close()

    buf := make([]byte, 65535)
    for {
        n, _, _ := sock.ReadFromUDP(buf)
        // وحدات بايت shred سولانا الخام — مرّرها إلى أداة فك التجميع / فك الترميز لديك.
        fmt.Printf("shred: %d bytes\n", n)
    }
}

// cargo add shredstream
use shredstream::ShredListener;

fn main() {
    let port: u16 = std::env::var("SHREDSTREAM_PORT")
        .ok().and_then(|v| v.parse().ok()).unwrap_or(8001);
    let mut listener = ShredListener::bind(port).expect("bind");

    // Client-side deshredding → ready Solana transactions
    for (slot, transactions) in listener.transactions() {
        for tx in &transactions {
            println!("slot {}: {}", slot, tx.signatures[0]);
        }
    }
}

# Linux
sudo sysctl -w net.core.rmem_max=33554432

# macOS
sudo sysctl -w kern.ipc.maxsockbuf=33554432