GAE Go1.11 のdev_appserver.pyでホットリロードが効かないとき

Go

GAE Go1.11 の dev_appserver.py でホットリロードが効かないなーというとき、dev_appserver.py実行時に以下のメッセージが出力されてました。最後の1行が出力されているとホットリロードが効きません。 $ dev_appserver.py dev.yaml INFO 2019-09-22 10:30:…

2019-05-31

SQLアンチパターン・ジェイウォークのクエリをシェルでやる

シェル

SQLアンチパターンという本があります。その本の1章がジェイウォーク（信号無視）。ジェイウォークで紹介されているようなデータがtsvファイルとして手元にある場合に、SQLではなくシェルでなんとかするお話です。ジェイウォーク tsvファイル SQL vs シェ…

2019-05-12

MQTTサーバーを実装しながらGoを学ぶ - その１２ Contextを使ったgoroutineの停止

Go MQTT

前回、別goroutineで発生したエラーハンドリングをしました。具体的にはサブスクライバへの書き込みでエラーが発生した場合にサブスクリプションの削除処理するようにしました。今回は、 context.Context を使ってgoroutineを停止することで、クライアントが…

2019-05-06

MQTTサーバーを実装しながらGoを学ぶ - その１１ goroutineのエラーハンドリング, map, goroutineセーフ

Go MQTT

前回の続き。別のgoroutineで発生したエラーをerror channelを使ってハンドリングしてみたいと思います。ハンドリングの処理でmapを使ったのですが、goroutineセーフにするため sync.Map を使ってみました。目次。 handleSub でエラー別goroutineを受け取…

2019-05-04

MQTTサーバーを実装しながらGoを学ぶ - その１０ type, "chan<-"と"<-chan"

Go MQTT

前回、goroutine, channel, selectを使って Broker を実装しました。この Broker をサーバーで利用し、MQTTでメッセージを配送してみます。その前に <-chan chan<- []byte という型が読みづらいので type を使って対応します。その後、読み書き可能なchanne…

2019-05-03

MQTTサーバーを実装しながらGoを学ぶ - その９ channelとselect

Go MQTT

前回はgoroutineを使って、複数クライアントと同時に接続できるようにしました。今回は、複数のgoroutine間をchannelをつないでメッセージやりとりし、Publishされたメッセージを別のSubscribeしているクライアントに配送します。channelの所有権やselectを…

2019-04-27

MQTTサーバーを実装しながらGoを学ぶ - その８ goroutine, pprof

Go MQTT

前回までで、クライアントがPUBLISH、またはSUBSCRIBEすることができるようになりました。次は、クライアントからPUBLISHされたメッセージを、SUBSCRIBEしている別のクライアントへ送る処理を実装していきます。が、その前にgoroutineを使ってサーバーが複数…

2019-03-16

MQTTサーバーを実装しながらGoを学ぶ - その７ type switch, interface再考, プライベートな関数のテスト

Go MQTT

前回で、クライアントからのPUBLISHを受け取るところまで実装できました。今回はSUBSCRIBEを受け取るところを実装します。いつも引用してる図で言うと、右側の「Computer」や「Mobile device」からMQTT Brokerへの通信です。引用元：https://www.appcelerat…

2019-03-09

MQTTサーバーを実装しながらGoを学ぶ - その６ const, iota

Go MQTT

前回の続きです。handlerのエラーハンドリングからやります。その後、mosquitto_clientからPUBLISHパケットを自作サーバーで受け取れるようにしました。最後にhandlerのリファクタリングで Untyped constant declaration というconstの便利な使い方を知りま…

2019-02-18

MQTTサーバーを実装しながらGoを学ぶ - その５ net, io, bufioパッケージ

Go MQTT

前回の続きです。前回までで一応 CONNECTパケットをstructに変換する処理ができました。これでクライアントからのCONNECTパケットをサーバー側で解釈できます。今回は、CONNECTに対するレスポンスであるCONNACKに取り掛かります。また、実際にサーバーとし…

2019-02-12

MQTTサーバーを実装しながらGoを学ぶ - その４テストカバレッジ

Go MQTT

前回の続きです。今回は、MQTTのCONNECTパケットのペイロードから。ペイロードをbinaryパッケージを使って実装します。その後、regexパッケージを使って入力チェック処理を書いてテストします。Goではテストカバレッジが簡単に取得できるようだったので、試…

2019-02-03

MQTTサーバーを実装しながらGoを学ぶ - その３ errorとエラーハンドリング

Go MQTT

前回で func ToFixedHeader(bs []byte) FixedHeader という関数を実装しました。この関数の引数のチェックとエラーハンドリングからやります。Goにおけるエラーハンドリングを学んでいきたいと思います。目次。 error CONNECTパケットの可変ヘッダー Goのエ…

2019-01-21

MQTTサーバーを実装しながらGoを学ぶ - その２ go vet, gofmt, go doc

Go MQTT

前回、固定ヘッダーを表すstructの実装に着手しました。 // fixed_header.go package packet type FixedHeader { PacketType byte } func ToFixedHeader(bs []byte) FixedHeader { b := bs[0] packetType := b >> 4 return FixedHeader{packetType} } ここか…