python測試rabbitmq的消息收發

send.py

<code>#!/usr/bin/env python   </code>

<code># -*- coding: UTF-8 -*- </code>

<code>import</code> <code>pika  </code>

<code>import</code> <code>random  </code>

<code>        </code> 

<code>credentials = pika.PlainCredentials(</code><code>'root'</code><code>, </code><code>'123456'</code><code>)  </code>

<code>#這裡可以連接配接遠端IP，請記得打開遠端端口    </code>

<code>parameters = pika.ConnectionParameters(</code><code>'139.x.x.x'</code><code>,5672,</code><code>'/'</code><code>,credentials)    </code>

<code>connection = pika.BlockingConnection(parameters)    </code>

<code>channel = connection.channel()    </code>

<code>    </code> 

<code>#channel.queue_declare(queue='hello')    </code>

<code>number = random.randint(1,1000)  </code>

<code>body = </code><code>'hello world:%s'</code> <code>%number  </code>

<code>channel.basic_publish(exchange=</code><code>''</code><code>,    </code>

<code>                      </code><code>routing_key=</code><code>'hello'</code><code>,    </code>

<code>                      </code><code>body=body)    </code>

<code>print </code><code>" [x] Sent %s"</code> <code>%body    </code>

<code>connection.close()</code>

receice.py

<code></code>

本文轉自 yanconggod 51CTO部落格，原文連結:http://blog.51cto.com/yanconggod/1953785