mq

Documentation

Index

• Variables
• func Connect(userName, password, address string)
• func Producer(queueName string, request []byte) error
• func Publish(exchangeName string, request []byte) error
• func RPCClient(queueName string, request []byte) (reply []byte, err error)
• func RPCServer(queueName string, f func([]byte) []byte)
• func Receive(QueueName string) (<-chan amqp.Delivery, error)
• func RouteConsume(ch *amqp.Channel, exchangeName, key string) (<-chan amqp.Delivery, error)
• func RoutePublish(exchangeName, key string, request []byte) error
• func Send(QueueName string, request []byte) error
• func Subscribe(exchangeName string) (<-chan amqp.Delivery, error)
• func TopicEmit(exchangeName, key string, request []byte) error
• func TopicReceive(exchangeName string, keys ...string) (<-chan amqp.Delivery, error)
• func Worker(queueName string) (<-chan amqp.Delivery, error)

Variables

var Conn *amqp.Connection

Functions

func Connect

func Connect(userName, password, address string)

func Producer

func Producer(queueName string, request []byte) error

worker模式

func Publish

func Publish(exchangeName string, request []byte) error

fanout，广播模式 开启持久化

func RPCClient

func RPCClient(queueName string, request []byte) (reply []byte, err error)

RPC模式

func RPCServer

func RPCServer(queueName string, f func([]byte) []byte)

func Receive

func Receive(QueueName string) (<-chan amqp.Delivery, error)

func RouteConsume

func RouteConsume(ch *amqp.Channel, exchangeName, key string) (<-chan amqp.Delivery, error)

一个线程用一个channel，多个go程共用一个channel

func RoutePublish

func RoutePublish(exchangeName, key string, request []byte) error

路由模式 关闭持久化

func Send

func Send(QueueName string, request []byte) error

普通模式 支持持久化

func Subscribe

func Subscribe(exchangeName string) (<-chan amqp.Delivery, error)

func TopicEmit

func TopicEmit(exchangeName, key string, request []byte) error

TOPIC模式

func TopicReceive

func TopicReceive(exchangeName string, keys ...string) (<-chan amqp.Delivery, error)

keys 绑定多个路由 key支持以下规则 *（星号）：可以（只能）匹配一个单词 #（井号）：可以匹配多个单词（或者零个）

func Worker

func Worker(queueName string) (<-chan amqp.Delivery, error)

worker使用时，必须手动ack