Действительно ли AMQP подходит и как intra и как шина программного обеспечения межмашины?

Question

Действительно ли AMQP подходит и как intra и как шина программного обеспечения межмашины?

Вы неправильно поняли, как работают Subscription и add.

Когда вы subscribe к чему-то, вы получаете объект Subscription, к которому вы можете обратиться unsubscribe(). Это отлично. Тем не менее, вы не присвоили значение правильно. Вы присвоили Subscription - const sub, которые затем передаете как блок completion на add.

Рассмотрим Subscription.add как блок finally из try/catch. Независимо от результата Subscription, когда он равен complete, блок, переданный в add, будет выполняться. Используйте это для любых задач очистки.

subscriptions: Subscriptions[] = [];

ngOnDestroy() {
   subscriptions.forEach((sub) => sub.unsubscribe());
}

deleteFile(id: any) {
   const sub = this.fileCabinetService.deleteFile(id).subscribe(...);
   this.subscriptions.push(sub);
   sub.add(() => this.subscriptions.remove(sub));
}

Чтобы ответить на ваш вопрос о том, когда unsubscribe, это действительно зависит от того, что deleteFile делает. Если метод deleteFile внутренне сигнализирует со значением (или набором значений) и затем завершается, подписка прекращается автоматически. Если оно не будет завершено и оставлено висящим, ваша подписка будет сохраняться.

Рассмотрим сценарий:

WallClock.subscribe((time) => console.log(time));

Этот Subscription никогда не будет прекращен, потому что время (предположительно) будет продолжаться бесконечно. Вместо этого вы захотите вручную контролировать, когда это будет прекращено. Вы можете сделать это несколькими способами:

/* Get the current time, but don't bother listening to updates. */
WallClock.pipe(take(1)).subscribe((time) => console.log(time));

/* Continually update with the current time as long as the component is on screen
   — Requires setting `this.staySubscribed = false` when you're leaving */
WallClock.pipe(takeWhile(() => this.staySubscribed)).subscribe((time) => console.log(time));

/* Continually update until you remember to unsubscribe
   — Requires remembering to unsubscribe and can get verbose with multiple subscriptions
   - Call `this.subscription.unsubscribe()` later */
this.subscription = WallClock.subscribe((time) => console.log(time));

Если ваш deleteFile работает так и непрерывно сообщает значения без определенного условия завершения, вы должны каким-то образом прекратить подписку. Вероятно, это случай (основанный на названии функции), что это самоограничение Subscription, которое не требует ничего с вашей стороны. Если вы хотите быть в безопасности, pipe(take(1)) обеспечит это для вас.

9

amqp distributed message-queue architecture

задан Bwooce 30 October 2008 в 23:16

6 ответов

AMQP является спецификацией, таким образом, Вы сравнили бы яблоки с апельсинами действительно. Нет то, что многие производство готовые поставщики AMQP там действительно; ни один из главных поставщиков сообщений или поставщиков не поддерживает AMQP во время записи (например, IBM, Tibco, Звуковой, BEA, Oracle, SwiftMQ, Миссисипи, Apache ActiveMQ, openmq от Sun) - таким образом, все доступные поставщики AMQP являются довольно новыми.

Таким образом, я рекомендовал бы выдержать сравнение безотносительно поставщика AMQP Вы интересуетесь с Вашей платформой передачи сообщений. Нет никакого смысла разрывающего что-то, которое хорошо работает только из-за способа, которым это читает и пишет байты в сокет :)

2