rabbitmesh 0.1.0

Message-driven microservices framework using RabbitMQ for zero-port service mesh
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

# 🚀 RabbitMesh - Message-Driven Microservices Framework

**Zero-port microservices with auto-generated APIs**

RabbitMesh eliminates traditional microservice complexity by using RabbitMQ for all inter-service communication. Write business logic, get REST + GraphQL APIs automatically.

## ✨ Key Features

- **🔥 Zero Port Management** - Services only connect to RabbitMQ
- **⚡ Never Blocks** - Every request spawns async task  
- **🎯 Auto-Generated APIs** - Write service methods, get REST + GraphQL
- **🛡️ Production Ready** - Built-in retries, timeouts, load balancing
- **🌍 Deploy Anywhere** - Docker, Kubernetes, bare metal

## 🚀 Quick Start

### 1. Define Your Service

```rust
use rabbitmesh_macros::{service_definition, service_method};

#[service_definition]
pub struct UserService;

impl UserService {
    #[service_method("GET /users/:id")]
    pub async fn get_user(user_id: u32) -> Result<User, String> {
        // Your business logic only
        Ok(User { id: user_id, name: "John".to_string() })
    }
    
    #[service_method("POST /users")]  
    pub async fn create_user(data: CreateUserRequest) -> Result<User, String> {
        // Handle user creation
        Ok(User { id: 1, name: data.name })
    }
}
```

### 2. Start Your Service

```rust
use rabbitmesh::MicroService;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let service = MicroService::new("amqp://localhost:5672").await?;
    service.start().await?;  // Never blocks, handles requests concurrently
    Ok(())
}
```

### 3. Auto-Generated API Gateway

```rust
use rabbitmesh_gateway::create_auto_router;

#[tokio::main] 
async fn main() {
    let app = create_auto_router().await;
    
    // Automatically provides:
    // GET  /api/v1/user-service/users/123
    // POST /api/v1/user-service/users
    // GraphQL endpoint at /graphql
    
    axum::Server::bind(&"0.0.0.0:3000".parse().unwrap())
        .serve(app.into_make_service())
        .await
        .unwrap();
}
```

## 🏗️ Architecture

```
┌─────────────┐    ┌─────────────┐    ┌─────────────────────────────────┐
│   Frontend  │────│ API Gateway │────│        Service Mesh             │
│  (NextJS)   │HTTP│ (Auto-Gen)  │AMQP│  ┌─────┐ ┌─────┐ ┌─────┐      │
│             │    │             │    │  │User │ │Auth │ │Order│ ...  │
└─────────────┘    └─────────────┘    │  └─────┘ └─────┘ └─────┘      │
                                      │           │                    │
                                      │     ┌─────────────┐            │
                                      │     │  RabbitMQ   │            │
                                      │     │   Broker    │            │
                                      └─────┴─────────────┴────────────┘
```

## 📦 Crates

- **`rabbitmesh`** - Core microservice framework  
- **`rabbitmesh-macros`** - Code generation macros
- **`rabbitmesh-gateway`** - Auto-generating API gateway
- **`examples/ecommerce`** - Complete demo application

## 🎯 Why RabbitMesh?

| Traditional HTTP | RabbitMesh |
|------------------|------------|
| ❌ Port management hell | ✅ Zero ports to manage |
| ❌ Manual load balancing | ✅ Automatic via RabbitMQ |
| ❌ Service discovery complexity | ✅ Auto-discovery via queues |
| ❌ Blocking request handlers | ✅ Every request is async |
| ❌ Manual API development | ✅ Auto-generated REST + GraphQL |

## 🚀 Performance

- **Latency**: 3-10ms (vs 1-5ms HTTP direct)
- **Throughput**: Higher than HTTP (persistent connections)
- **Concurrency**: Unlimited (every request = async task)
- **Scalability**: Linear (add instances = proportional capacity)

## 📋 Getting Started

See the [examples/ecommerce](examples/ecommerce) directory for a complete microservices demo with user management, authentication, and API gateway.

## 📄 License

MIT license