まずPodfileです。
platform :ios, '11.0'
target 'YourProject' do
# Comment the next line if you're not using Swift and don't want to use dynamic frameworks
use_frameworks!
# Pods for YourProject
pod 'Moscapsule', :git => 'https://github.com/flightonary/Moscapsule.git', :branch => 'swift4'
pod 'OpenSSL-Universal'
end
次に実装を示します。
import Moscapsule した上で、以下のようにFirstViewController等に記述して下さい。
{
...
private var _timer: Timer?
private var mqttConfig: MQTTConfig!
private var mqttClient: MQTTClient!
// MARK: - オーバーライド
override func viewDidLoad() {
super.viewDidLoad()
//MQTTコールバック登録
moscapsule_init()
mqttConfig = MQTTConfig(clientId: NSUUID().uuidString, host: "ホスト名", port: ポート番号, keepAlive: 60)
mqttConfig.mqttAuthOpts = MQTTAuthOpts(username: "", password: "")
mqttConfig.cleanSession = true
if let path = Bundle.main.path(forResource: "ファイル名", ofType: "crt") {
mqttConfig.mqttServerCert = MQTTServerCert(cafile: path, capath: nil)
}
mqttConfig.onMessageCallback = { mqttMessage in
if mqttMessage.topic == "トピック" {
if let msg = mqttMessage.payloadString {
DispatchQueue.main.async { self.onMQTT(msg: msg) }
}
}
}
}
override func viewDidAppear(_ animated: Bool) {
super.viewDidAppear(animated)
//MQTT接続、一定時間毎にsubscribe発行したいため、タイマーを用いる
wakeupTimer()
}
override func viewWillDisappear(_ animated: Bool) {
super.viewWillDisappear(animated)
mqttClient.unsubscribe("トピック", requestCompletion: nil)
sleepTimer()
}
// MARK: - MQTT発行、受信
func wakeupTimer() {
mqttClient = MQTT.newConnection(mqttConfig)
_timer = Timer.scheduledTimer(timeInterval: 10, target: self, selector: #selector(onTimer), userInfo: nil, repeats: true)
_timer?.fire()
}
func sleepTimer() {
mqttClient.disconnect()
_timer?.invalidate()
}
@objc func onTimer() {
if mqttClient.isConnected {
mqttClient.subscribe("トピック", qos: 0)
} else {
DispatchQueue.main.asyncAfter(deadline: .now() + 1, execute: {
self._timer?.fire()
})
print("1秒タイマー動作")
}
}
func onMQTT(msg m: String) {
mqttClient.unsubscribe("トピック", requestCompletion: nil)
let ary: [String] = m.components(separatedBy: "}")
for item in ary {
let data: [String] = item.components(separatedBy: ",")
if (data.count > 個数) {
お好きなように！
}
}
}
}
1. 概要
すでにサーバーでbroker(mosquitto)が動作していることが前提となります。
そのbrokerに対して、一定時間(ここでは10秒)ごとに、subscribeし、onMQTTで文字列を受け取ります。
通信が途切れた場合は、1秒後に再接続を試みます。
2. セキュリティ
平文を避けるため、brokerではTLSを動作させるものとします。
たぶんmosquittoの仕様だと思うのですが、TLSでアクセスするには、サーバー証明書が要るようです。
moscapsuleを使った本実装例は、コマンドラインからの
mosquitto_sub -h ホスト -p ポート -t トピック --cafile ファイル
の実行と、等価なはずです。
3. さらなるセキュリティ
やってないですが、mqttClientCertで、クライアント証明書を指定すればいいようです。
mosquitto_subのオプション--certと--keyを使うことと、等価なはずです。
4. 受信文字列
文字列はカンマ区切りの羅列を想定しています。
JSONを使うのが一般的なようですが、オレオレサーバー<=>アプリ間なら、単なるカンマ区切りがおすすめです。
5. タイマー
別にタイマーである必要はないのですが、iOSアプリでMQTTを受信して何かさせたいとなると、こうする以外ないような気がします。
アプリがバックグラウンドに隠れたり、アプリ内でタブを切り替えたりすることに備えて、AppDelegateに以下の実装も加えて下さい。
func applicationDidEnterBackground(_ application: UIApplication) {
デリゲート.sleepTimer()
}
func applicationWillEnterForeground(_ application: UIApplication) {
デリゲート.wakeupTimer()
}
6. 謝辞
@fuku2014さんの記事を参考にさせていただきました。
https://qiita.com/fuku2014/items/2b8f76c6e60bc9ff14db
なお、brokerの立て方、証明書の作り方等は、以下に詳しいです。
https://ficus-forum.myvnc.com/t/mosquitto-tls-ssl/154
https://qiita.com/udai1532/items/c0f58e73f76900a8469f
