PHPackages                             yjtec/laravel-amqp-link - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Queues & Workers](/categories/queues)
4. /
5. yjtec/laravel-amqp-link

ActiveLibrary[Queues & Workers](/categories/queues)

yjtec/laravel-amqp-link
=======================

Laravel AMQP

v0.0.1.4(6y ago)14.1kMITPHPPHP >=7.0

Since Nov 19Pushed 6y ago1 watchersCompare

[ Source](https://github.com/yjtec/laravel-amqp-link)[ Packagist](https://packagist.org/packages/yjtec/laravel-amqp-link)[ RSS](/packages/yjtec-laravel-amqp-link/feed)WikiDiscussions master Synced 3w ago

READMEChangelogDependencies (1)Versions (6)Used By (0)

发布消息
----

[](#发布消息)

### 用路由键推送消息

[](#用路由键推送消息)

```
    AmqpLink::publish('routing-key', 'message');
```

### 用路由键推送消息并创建队列

[](#用路由键推送消息并创建队列)

```
    AmqpLink::publish('routing-key', 'message' , ['queue' => 'queue-name']);
```

### 带有路由键和覆盖属性的推送消息

[](#带有路由键和覆盖属性的推送消息)

```
    AmqpLink::publish('routing-key', 'message' , ['exchange' => 'amq.direct']);
```

消费信息
----

[](#消费信息)

### 消费消息，确认并在没有消息时停止

[](#消费消息确认并在没有消息时停止)

```
AmqpLink::consume('queue-name', function ($message, $resolver) {

   var_dump($message->body);

   $resolver->acknowledge($message);

   $resolver->stopWhenProcessed();

});
```

### 永远消耗消息

[](#永远消耗消息)

```
AmqpLink::consume('queue-name', function ($message, $resolver) {

   var_dump($message->body);

   $resolver->acknowledge($message);

});
```

### 自定义监听路由

[](#自定义监听路由)

```
AmqpLink::consume('queue-name', function ($message, $resolver) {

   var_dump($message->body);

   $resolver->acknowledge($message);

}, ['*', 'test.*']);
```

### 使用自定义设置来消费消息

[](#使用自定义设置来消费消息)

```
AmqpLink::consume('queue-name', function ($message, $resolver) {

   var_dump($message->body);

   $resolver->acknowledge($message);

}, [], [
	'timeout' => 2,
	'vhost'   => 'vhost3'
]);
```

扇出示例
----

[](#扇出示例)

### 发布消息

[](#发布消息-1)

```
\AmqpLink::publish('', 'message' , [
    'exchange_type' => 'fanout',
    'exchange' => 'amq.fanout',
]);
```

### 消费信息

[](#消费信息-1)

```
\AmqpLink::consume('', function ($message, $resolver) {
    var_dump($message->body);
    $resolver->acknowledge($message);
}, [
    'exchange' => 'amq.fanout',
    'exchange_type' => 'fanout',
    'queue_force_declare' => true,
    'queue_exclusive' => true,
    'persistent' => true // required if you want to listen forever
]);
```

###  Health Score

26

—

LowBetter than 41% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity19

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity47

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~1 days

Total

5

Last Release

2409d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/48311842?v=4)[Yjtec](/maintainers/Yjtec)[@yjtec](https://github.com/yjtec)

---

Top Contributors

[![kkw-h](https://avatars.githubusercontent.com/u/24262474?v=4)](https://github.com/kkw-h "kkw-h (8 commits)")

### Embed Badge

![Health badge](/badges/yjtec-laravel-amqp-link/health.svg)

```
[![Health](https://phpackages.com/badges/yjtec-laravel-amqp-link/health.svg)](https://phpackages.com/packages/yjtec-laravel-amqp-link)
```

###  Alternatives

[vladimir-yuldashev/laravel-queue-rabbitmq

RabbitMQ driver for Laravel Queue. Supports Laravel Horizon.

2.1k10.3M32](/packages/vladimir-yuldashev-laravel-queue-rabbitmq)[bschmitt/laravel-amqp

AMQP wrapper for Laravel and Lumen to publish and consume messages

2792.4M7](/packages/bschmitt-laravel-amqp)[jwage/phpamqplib-messenger

Symfony messenger transport for the php-amqplib/php-amqplib library.

87201.9k1](/packages/jwage-phpamqplib-messenger)[hyperf/amqp

A amqplib for hyperf.

231.2M66](/packages/hyperf-amqp)[convenia/pigeon

3234.2k](/packages/convenia-pigeon)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)