Skip to content

A simple RPC client/server library based on rabbitmq

License

Notifications You must be signed in to change notification settings

MidTin/rabbit-rpc

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

30 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Rabbit RPC

简述

这是对 RabbitMQ 的 Pika 库进行封装的,一套简易 RPC 客户端/服务端库。

安装说明

pip install rabbit-rpc

使用事例

服务端

# project/consumers.py

from rabbit_rpc.consumer import consumer

@consumer(name='add')
def add(a, b):
    return a + b


# project shell
rabbit_rpc worker --amqp 'amqp://guest:guest@localhost:5672/'


# with django

rabbit_rpc worker --amqp 'amqp://guest:guest@localhost:5672/' --django project

客户端

from rabbit_rpc.client import RPCClient

client = RPCClient(amqp_url='amqp://guest:guest@localhost:5672/')
ret = client.call_add(1, 1, timeout=1)

# or ignore result
client.call_add(1, 1, ignore_result=True)

# specify routing_key
client.call_add(1, 1, routing_key='default')

About

A simple RPC client/server library based on rabbitmq

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages