• 0 : 메시지는 한번만 전달하며, 전달여부를 확인하지 않는다. Fire and Forget 타입이다.
• 1 : 메시지는 반드시 한번 이상 전달된다. 하지만 메시지의 핸드셰이킹 과정을 엄밀하게 추적하지 않기 때문에, 중복전송될 수도 있다.
• 2 : 메시지는 한번만 전달된다. 메시지의 핸드셰이킹 과정을 추적한다. 높은 품질을 보장하지만 성능의 희생이 따른다.

• VirtualBox를 이용해서 PUB, SUB, Broker를 위한 3개의 게스트 운영체제를 실행했다. 호스트 이름은 각각 pub.local, sub.local, broker.local 이다.
• 게스트 운영체제 : 우분투 리눅스 14.04로 통일

broker.local # netstat -nap | grep mosquitto
tcp        0      0 0.0.0.0:1883            0.0.0.0:*               LISTEN      1512/mosquitto  
tcp6       0      0 :::1883                 :::*                    LISTEN      1512/mosquitto  

# apt-get install mosquitto-clients

# mosquitto_sub -d -t hello/world
Received CONNACK
Received SUBACK
Subscribed (mid: 1): 0

# mosquitto_pub -d -t hello/world -m "Hello World"
Received CONNACK
Sending PUBLISH (d0, q0, r0, m1, 'hello/world', ... (11 bytes))

# rabbitmq-plugins enable rabbitmq_mqtt
The following plugins have been enabled:
   amqp_client
     rabbitmq_mqtt
     Plugin configuration has changed. Restart RabbitMQ for changes to take effect.

• 채팅방 생성 : 채팅방을 Topic으로 하면 된다. Topic을 늘리는 것으로 여러 개의 채팅방을 운용할 수도 있을 거다. 채팅방을 임의로 만들게 하는 건 귀찮으니.. 그냥 "chat/public", "chat/private" 두개의 채팅방만 만들기로 했다.

1. MQTT 브로커로는 앞서 다룬 모스키토를 사용했다.
2. 쓰레드 하나는 Sub 전용이다. 토픽으로 받은 정보를 화면에 출력한다.
   • chat/public : 공개 채널의 메시지를 받기 위해서 사용한다.
   • chat/public/nickname : 자신의 nicname 토픽에 메시지를 받기 위함.
3. 쓰레드 하나는 Pub 전용이다. 표준입력을 토픽에 publishing 한다.
   • chat/public : 공개 채널에 publishing 한다.
4. chat/public/other : 특정 유저에게 publishing 하기 위해서 사용한다.

• 우분투 리눅스 14.04
• Ruby 1.9.3
• mqtt broker : mosquitto

# gem install mqtt

• 공개 메시지 : message
• 개인 메시지 : /priv nickname message
• 채팅방 나가기 : /quit message

require 'rubygems'
require 'mqtt'
require 'readline'            

# nickname 설정    
nickname=ARGV[0]              

# localhost에서 테스트 했다.
mqtt = MQTT::Client.new('localhost')

mqtt.connect do |client|
    client.subscribe('chat/public')
    client.subscribe("chat/private/#{nickname}")
    enter_msg = "#{nickname} enter room!!"
    client.publish 'chat/public', enter_msg

    # Publish Thread
    Thread.new do
        while message = Readline.readline("", true)
            case message
            when /^\/priv\s*(\w*)\s*(.*)/       # 개인 메시지
                client.publish "chat/private/#{$1}", "<#{nickname}> : #{$2}"
            when /^\/quit\s*(.*)/               # 나가기 
                client.publish 'chat/public', "#{nickname} has quit (#{$1})"
                exit 1
            else                                # 공개 메시지
                client.publish 'chat/public', "#{nickname} : #{message}"
            end
        end
    end

    loop do
        topic, message = client.get    
        print message,"\n"
    end
end

• Byte 2만 사용할 경우 127 byte 크기의 메시지를 다룰 수 있다. 만약 127 byte를 초과 한다면
• Byte 3를 사용해야 한다. 마찬가지로 1개 bit는 reamining byte를 사용할 건지 결정하기 위해서 남겨둬야 한다. 전체 2바이트 에서 2개의 비트를 예약 했으니 16383까지 표현할 수 있다.
• Byte 4도 같은 방법으로 계산 하면 2,097,151 까지 표현할 수 있다.
• Byte 5는 최대 268,435,455를 사용할 수 있다. 4개의 비트를 사용할 수 없으니 2^28 - 1 = 268435455이다.

1. 소형 장비의 센서를 수집하고 제어하기 위한 Gateway가 있을 수 있다.
2. AllSeen 혹은 OIC Gateway가 있다. 이들은 Local의 기기를 discovery하고, 메시지를 중계하는 브로커 역할을 한다. 그리고 IoT Internet Infra로의 연결을 위한 인터넷 게이트웨이 역할을 한다.
3. IoT Internet Infra의 연결에 MQTT를 사용한다.

1. 유저 모바일 애플리케이션 : 채널을 분리한다. 메시지는 HTTP 기반으로 전송하고, 응답은 MQTT client로 받는다. 네이티브 혹은 하이브리드 앱에서 사용할 수 있다.
2. 웹 브라우저 : HTTP로 전송하는 건 동일하다. 응답은 웹 소켓을 이용한다. 많은 MQTT 브로커들이 웹 소켓 인터페이스를 제공한다.
3. 소형 디바이스 : MQTT 단일 인터페이스로 송/수신한다.
4. 웹 애플리케이션 : 그림에는 없지만, 인터넷 서비스와 Server - to - Server 방식으로 연결할 수 있다. 이 경우 양측이 OpenAPI›를 제공하고, 서로 호출하는 방식을 사용한다.

• http://madalanarayana.wordpress.com/2014/03/25/learnings-on-publish-subscribe-mqtt-mosquitto/
• Building FaceBook messenger
• Message Broker Technology for flexible signalling control
• MQTT 브로커 기능 비교
• MQTT V3.1 Protocol Specification
• MQTT man page