MQ进阶[持续进行中]

[itang]

apache-kafka

• [ ] Current and Future of Apache Kafka 490 http://www.slideshare.net/charmalloc/current-and-future-of-apache-kafka -1. [ ] http://blog.cloudera.com/blog/2014/09/apache-kafka-for-beginners/
  1. [ ] mqtt-kafka http://www.slideshare.net/kellogh/mqtt-kafka-33100776
  2. [ ] Announcing HDP Tech Preview Component: Apache Kafka http://hortonworks.com/blog/announcing-apache-kafka-technical-preview-hdp-2-1/
• [ ] http://www.infoq.com/cn/articles/apache-kafka
• [ ] kafka的性能 http://engineering.linkedin.com/kafka/benchmarking-apache-kafka-2-million-writes-second-three-cheap-machines
• [ ] The future is Micro Service Architectures on Apache Karaf http://blog.eisele.net/2014/10/the-future-is-micro-service-architectures-with-apache-karaf.html
• [ ] http://www.cloudera.com/content/cloudera/en/developers/home/cloudera-labs/apache-kafka.html

  更多

  1. [ ] 了解nanomsg及其通讯模式

http://tim.dysinger.net/posts/2013-09-16-getting-started-with-nanomsg.html

http://www.bravenewgeek.com/a-look-at-nanomsg-and-scalability-protocols/

1. [ ] HornetQ http://hornetq.jboss.org/

2. [ ] rabbitmq http://www.rabbitmq.com/

   【架构】关于RabbitMQ

   • [ ] http://blog.x-aeon.com/2013/04/10/a-quick-message-queue-benchmark-activemq-rabbitmq-hornetq-qpid-apollo/

     MQTT

3. [ ] 熟悉 http://mqtt.org/
   • [ ] Choosing Your Messaging Protocol: AMQP, MQTT, or STOMP http://blogs.vmware.com/vfabric/2013/02/choosing-your-messaging-protocol-amqp-mqtt-or-stomp.html
   • [x] http://www.rabbitmq.com/mqtt.html
   • [ ] http://www.infoq.com/articles/event-tracking-rabbitmq-fautsch

     Rabbitmq

     命令

rabbitmq-plugins, rabbitmq-server, rabbitmqctl

启动： sudo rabbitmq-server & 状态： sudo rabbitmqctl status 停止： sudo rabbitmqctl stop

查看队列： sudo rabbitmqctl list_queues sudo rabbitmqctl list_queues name messages_ready messages_unacknowledged

查看exchange sudo rabbitmqctl list_exchanges

查看binding sudo rabbitmqctl list_bindings

启用插件： sudo rabbitmq-plugins enable rabbitmq_mqtt

sudo rabbitmq-plugins enable rabbitmq_stomp

概念，术语

ACK(Acknowledgement) 即确认字符，在数据通信中，接收站发给发送站的一种传输类控制字符。表示发来的数据已确认接收无误。

MQTT

• QoS0 and QoS1

Transient (QoS0) subscription use non-durable, auto-delete queues that will be deleted when the client disconnects.

Durable (QoS1) subscriptions use durable queues. Whether the queues are auto-deleted is controlled by the client's clean session flag. Clients with clean sessions use auto-deleted queues, others use non-auto-deleted ones.

• subscription_ttl

The subscription_ttl option controls the lifetime of non-clean sessions. This option is interpreted in the same way as the queue TTL parameter, so the value 1800000 means 30 minutes.

• prefetch

The prefetch option controls the maximum number of unacknowledged messages that will be delivered. This option is interpreted in the same way as the AMQP prefetch-count field, so a value of 0 means "no limit".

• producer queue consumer exchange

A producer is a user application that sends messages.

A queue is a buffer that stores messages.

A consumer is a user application that receives messages.

An exchange is a very simple thing. On one side it receives messages from producers and the other side it pushes them to queues.

direct exchange: a message goes to the queues whose binding key exactly matches the routing key of the message

topic exchange: is similar to a direct one - a message sent with a particular routing key will be delivered to all the queues that are bound with a matching binding key. However there are two important special cases for binding keys:

• (star) can substitute for exactly one word.

  (hash) can substitute for zero or more words.

  理解

队列模式：

“立即都模式”： 非持久化非ack： 将礼物”都“分给不同的receiver， ”有先来后到“ round-robin: ”带位置信息的分发模式“： 持久化， ack； 将任务”均“分给不同的task

[itang]

uninstall:

$ sudo apt-get remove rabbitmq-server $ sudo apt-get autoremove