如何使用 RabbitMQ 在两个 Android 应用程序之间发送消息

发布于 2024-12-17 20:35:34 字数 363 浏览 0 评论 0原文

我使用 RabbitMQ-Android 教程在 Android 中为 RabbitMQ 创建了一个应用程序。它运行良好。现在我想在 Android 中创建两个应用程序,并想使用 RabbitMQ 在它们之间进行通信。

我还没有找到有关此问题的任何示例或教程。 如果您可以提供代码链接,这将是一个很大的帮助。


感谢您的回复。我仅使用本教程创建了我的第一个应用程序。但本教程展示了通过 RabbitMQ 在 Android 和 .NET 应用程序之间进行连接。我没有 .NET 应用程序。因此,我想在 Android 中再创建一个应用程序,并且我想使用 RabbitMQ 在这两个应用程序之间发送消息。

是否可以?? 请给我关于这个主题的任何建议。 谢谢

I have created an application in Android for RabbitMQ using RabbitMQ-Android tutorial. It is working fine. Now I want to create two applications in Android and I want to make a communication between them using RabbitMQ.

I have not found any example nor tutorial regarding this issue.
It would be a great help, if you could provide a link with code.


Thanks for your reply. I have created my first application using this tutorial only. But this tutorial shows the connection between Android and .NET application through RabbitMQ. I don't have .NET application. So, I want to create one more application in Android, and I want to send message between these two applications using RabbitMQ.

Is it possible??
Please give me any suggestion on this topic.
Thanks

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

極樂鬼 2024-12-24 20:35:34

Simon Dixon 有一个很好的教程,应该可以帮助您入门:http://simonwdixon.wordpress.com/2011/06/03/getting-started-with-rabbitmq-on-android-part-1/

明天过后 2024-12-24 20:35:34

您可以使用下面的 Python 脚本将消息发送到 Android 客户端应用程序。

#!/usr/bin/env python
import pika
import time

connection = pika.BlockingConnection(pika.ConnectionParameters(
    host='localhost'))

channel = connection.channel()

channel.queue_declare(queue='hello')

i = 0

while True:

  channel.basic_publish(exchange='logs',
                      routing_key='hello',
                      body='Hello World, ' + str(i))
  print " [x] Sent 'Hello World!'" + str(i)
  i += 1
  time.sleep(1)
connection.close()

You can use a Python script below to send message to Android client application.

#!/usr/bin/env python
import pika
import time

connection = pika.BlockingConnection(pika.ConnectionParameters(
    host='localhost'))

channel = connection.channel()

channel.queue_declare(queue='hello')

i = 0

while True:

  channel.basic_publish(exchange='logs',
                      routing_key='hello',
                      body='Hello World, ' + str(i))
  print " [x] Sent 'Hello World!'" + str(i)
  i += 1
  time.sleep(1)
connection.close()
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文