RabbitMQ - История изменений

Sirmax: /* RabbitMQ */

2013-02-28T14:43:11Z

RabbitMQ

2012-12-06T14:00:31Z

Проверка (базовая)

← Предыдущая		Версия 14:00, 6 декабря 2012
Строка 168:		Строка 168:
	[root@rabbit1 ~]# ./new_task.py Test1234....		[root@rabbit1 ~]# ./new_task.py Test1234....
	[x] Sent 'Test1234....'		[x] Sent 'Test1234....'
		+	</PRE>
		+	Естественно в ./new_task.py поправлено
		+	<PRE>
		+	connection = pika.BlockingConnection(pika.ConnectionParameters(
		+	host='rabbit2'))
	</PRE>		</PRE>
	<PRE>		<PRE>

2012-12-06T13:59:22Z

Кластеризация

← Предыдущая		Версия 13:59, 6 декабря 2012
Строка 161:		Строка 161:
	...done.		...done.

		+	</PRE>
		+	===Проверка (базовая)===
		+	Отправить на одну ноду, получить с другой:
		+
		+	<PRE>
		+	[root@rabbit1 ~]# ./new_task.py Test1234....
		+	[x] Sent 'Test1234....'
		+	</PRE>
		+	<PRE>
		+	[root@rabbit1 ~]# ./worket.py
		+	[*] Waiting for messages. To exit press CTRL+C
		+	[x] Received 'Test1234....'
		+	[x] Done
	</PRE>		</PRE>

2012-12-06T13:57:11Z

Кластеризация

← Предыдущая		Версия 13:57, 6 декабря 2012
Строка 154:		Строка 154:
	Проверяю статус кластера:		Проверяю статус кластера:
	<PRE>		<PRE>
		+	[root@rabbit1 etc]# rabbitmqctl cluster_status
		+	Cluster status of node rabbit@rabbit1 ...
		+	[{nodes,[{disc,[rabbit@rabbit1]},{ram,[rabbit@rabbit2]}]},
		+	{running_nodes,[rabbit@rabbit2,rabbit@rabbit1]},
		+	{partitions,[]}]
		+	...done.

	</PRE>		</PRE>

2012-12-06T13:56:50Z

Кластеризация

2012-12-06T13:51:12Z

Кластеризация

@@ Строка 105: / Строка 105: @@
 <PRE>
 rabbitmqctl eval 'net_adm:ping(rabbit@rabbit1).'
 </PRE>
@@ Строка 111: / Строка 113: @@
 rabbitmqctl -n rabbit@rabbit1 status
 </PRE>
 ==Ссылки==
 * http://habrahabr.ru/post/150134/

2012-12-06T13:49:37Z

Ссылки

@@ Строка 95: / Строка 95: @@
 Т.е. похоже, работает =)
 ==Ссылки==
 * http://habrahabr.ru/post/150134/

2012-12-06T13:03:27Z

Отправка сообщения

← Предыдущая		Версия 13:03, 6 декабря 2012
Строка 82:		Строка 82:

	</PRE>		</PRE>
		+	====Тестирую отдельно-стоящего кроля ====
		+	<PRE>
		+	[root@localhost ~]# ./new_task.py 23421412......
		+	[x] Sent '23421412......'
		+	</PRE>
		+	<PRE>
		+	[root@localhost ~]# ./worket.py
		+	[*] Waiting for messages. To exit press CTRL+C
		+	[x] Received '23421412......'
		+	[x] Done
		+	</PRE>
		+	Т.е. похоже, работает =)

	==Ссылки==		==Ссылки==

2012-12-06T12:13:37Z

Отправка сообщения

@@ Строка 60: / Строка 60: @@
 ====Отправка сообщения====
 <PRE>
 </PRE>

2012-12-06T12:08:59Z

Проверка работы

← Предыдущая		Версия 12:08, 6 декабря 2012
Строка 31:		Строка 31:
	</PRE>		</PRE>
	===Проверка работы===		===Проверка работы===
		+	====Получение сообщения====
	Скрипт получения сообщений (с хабра) который обрабатывает "таск" столько секунд сколько точек в сообщении		Скрипт получения сообщений (с хабра) который обрабатывает "таск" столько секунд сколько точек в сообщении
	<PRE>		<PRE>
Строка 56:		Строка 57:

	channel.start_consuming()		channel.start_consuming()
		+	</PRE>
		+	====Отправка сообщения====
		+	<PRE>
	</PRE>		</PRE>