Swarms v2.0：全球首个基于 Rust 的多智能体框架

use swarms_rs::{Agent, Swarm, Message};

#[derive(Clone)]
struct MyAgent {
    id: String,
    state: AgentState,
}

impl Agent for MyAgent {
    async fn process_message(&mut self, message: Message) -> Vec<Message> {
        // Process incoming message
        match message.content {
            MessageContent::Task(task) => {
                let result = self.execute_task(task).await;
                vec![Message::new(self.id.clone(), result)]
            }
            _ => vec![]
        }
    }
}

#[tokio::main]
async fn main() {
    let mut swarm = Swarm::new();
    
    // Add agents to the swarm
    for i in 0..10 {
        swarm.add_agent(MyAgent::new(format!("agent-{}", i)));
    }
    
    // Start the swarm
    swarm.start().await;
}

cargo add swarms-rs

// Before (Python)
class MyAgent:
    def process_message(self, message):
        return self.handle_task(message)

// After (Rust)
impl Agent for MyAgent {
    async fn process_message(&mut self, message: Message) -> Vec<Message> {
        self.handle_task(message).await
    }
}

let config = SwarmConfig::new()
    .with_max_agents(1000)
    .with_message_timeout(Duration::from_secs(30))
    .with_retry_policy(RetryPolicy::exponential_backoff(3));

# Create a new project
cargo new my-swarms-app
cd my-swarms-app

# Add Swarms dependency
cargo add swarms-rs

# Run the example
cargo run --example basic_swarm

FROM rust:1.75 as builder
WORKDIR /app
COPY . .
RUN cargo build --release

FROM debian:bookworm-slim
COPY --from=builder /app/target/release/my-swarms-app /usr/local/bin/
CMD ["my-swarms-app"]