如何将 Pika 与 Qt 集成？

Question

最近，有用户询问如何将 Pika 与 Qt 一起使用，但没想到在我即将发布答案时该用户删除了，这让我有机会通过自动回答提出这个问题，我尝试公开各种解决方案：

Answer 1

使用BlockingConnection该start_consuming()方法必须在另一个线程中执行，此外必须知道回调是在辅助线程中执行的，因此如果您想更新 GUI，则必须发出信号

import threading

from PyQt5 import QtCore, QtWidgets
# or
# from PySide2 import QtCore, QtWidgets

import pika


class RabbitMQManager(QtCore.QObject):
    messageChanged = QtCore.pyqtSignal(str)
    # or
    # messageChanged = QtCore.Signal(str)

    def __init__(self, *, parameters=None, parent=None):
        super().__init__(parent)

        self._connection = pika.BlockingConnection(parameters)

    @property
    def connection(self):
        return self._connection

    def start(self):
        channel = self.connection.channel()
        channel.queue_declare(queue="hello")
        channel.basic_consume(
            queue="hello", on_message_callback=self._callback, auto_ack=True,
        )
        threading.Thread(target=channel.start_consuming, daemon=True).start()

        print(" [*] Waiting for messages. To exit press CTRL+C")

    def _callback(self, ch, method, properties, body):
        print(" [x] Received %r" % body)
        self.messageChanged.emit(body.decode())


def main():

    import signal
    import sys

    # https://stackoverflow.com/a/6072360
    signal.signal(signal.SIGINT, signal.SIG_DFL)

    app = QtWidgets.QApplication(sys.argv)

    w = QtWidgets.QTextEdit()
    w.resize(640, 480)
    w.show()

    credentials = pika.PlainCredentials("user", "user")
    parameters = pika.ConnectionParameters("127.0.0.1", 5672, "/", credentials)

    rabbit_manager = RabbitMQManager(parameters=parameters)
    rabbit_manager.start()

    rabbit_manager.messageChanged.connect(w.append)

    sys.exit(app.exec_())


if __name__ == "__main__":
    main()