消息推送系统

                import pika

                def send_message(message):
                    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
                    channel = connection.channel()
                    channel.queue_declare(queue='message_queue')
                    channel.basic_publish(exchange='', routing_key='message_queue', body=message)
                    print(" [x] Sent '" + message + "'")
                    connection.close()

                if __name__ == "__main__":
                    send_message("Hello, University of Agriculture!")