supervisorのメッセージキューが溜まる つい先日, supervisorのメッセージキューが溜まり続けていたので教訓として残す. start_child, terminate_child, etc...の実装について start_childを例に取る. 見ての通り, supervisorはgen_server behaviourで定義されており, start_childは内部的にはgen_server:call/3 (timeout: infinity) が呼ばれる. その後, ここでChildSpecに則り, 起動処理を行う. 起動処理は単純でerlang:apply/3の結果を見て, 成功していればChildSpecを保存・管理する. gen_serverの起動処理 子の起動処理として以下の関数をここでは以下を想定しよう. -module(hoge_server). -beha
はじめに 世間ではM2MとかIoTとか流行しています。兎にも角にもモノでインターネットしてくれよこのやろう、みたいな案件があちらこちらに飛びかっており、ms単位での応答を求められる顧客からの要求に担当者が絶叫する世界です。 こと速度を優先するならmqttかwebsocketな世の中。 尚且つエンプラで頑張るというのであれば、時代のmqttに。 ということで、今流行のmqttブローカーvernemqをインストールして、phoenixが行っているコンポーネント間のメッセージングをvernemq経由とするまでやってみようと思います。 mqtt界隈のサイヤ人と呼ばれるvの人お墨付きなので、将来性抜群のブローカーです。 例によって動作確認はcentos6となります。恐らくcentos7でも動作すると思います（init.d周りを除く）。デビアンマンの方は、適宜読み替えて下さい。やはりOSは枯れていない
イベントループ (event loop)、メッセージディスパッチャ (message dispatcher)、メッセージループ (message loop)、メッセージポンプ (message pump)、ランループ (run loop) とは、プログラム内でイベントやメッセージを待ち受け、それらをディスパッチ（配送）する構成要素である。内部または外部の「イベントプロバイダー」（通常、イベントが到着するまで要求をブロックする）に要求することで動作し、次いで適当なイベントハンドラー (event handler) を呼び出す（イベントのディスパッチ）。イベントプロバイダーが後述のファイルインタフェースに従う場合、イベントループは reactor と連携する形で使われることがあり、select() または poll() を使ってファイルインタフェースにアクセスする。イベントループはほぼ常にメッ
The Guide is copyright (c) 2010-2012 Pieter Hintjens. It is licensed under the Creative Commons Attribution-Non-Commercial-Share Alike 3.0 License. The examples are copyright their respective authors and licensed under MIT/X11 as follows:) Copyright (c) 2010-2012 iMatix Corporation and Contributors Permission is hereby granted, free of charge, to any person obtaining a copy of this software and as
Why ZeroMQ? ZeroMQ (also known as ØMQ, 0MQ, or zmq) looks like an embeddable networking library but acts like a concurrency framework. It gives you sockets that carry atomic messages across various transports like in-process, inter-process, TCP, and multicast. You can connect sockets N-to-N with patterns like fan-out, pub-sub, task distribution, and request-reply. It's fast enough to be the fabric
At Citrine, we have a long data pipeline that processes data uploaded by our users. This data can be as simple as a basic PDF document, or as complex as a rigidly structured set of materials properties in a CSV or JSON file.To make it easy for clients in multiple languages to join the fun, we chose RabbitMQ for messaging. This post has a few tips & tricks you might find handy when using RabbitMQ w
RabbitMQとはAMQP対応のメッセージキューイングシステムです。 何ができるかというと、遅い処理をキューに貯めてあとで処理することで高速なレスポンスを返すとができます。 もう少しわかりやすく表すとこんな感じです。 メッセージキューシステムを使わない場合 メッセージキューシステムを使う場合 では、さっそく使ってみます RabbitMQのインストール 今回はrubyのbunnyでRabbitMQを使ってみました。 bunnyのインストール $ curl -sSL https://get.rvm.io | bash -s stable $ export PATH=$PATH:/usr/local/rvm/bin/ $ rvm install ruby-2.1.1 $ rvm use ruby-2.1.1 $ gem install bunny --version ">= 0.9.1" er
アメーバ事業本部 API 基盤グループでプログラマをしている @na_ga です。 API 基盤グループでは、弊社の様々なサービスから利用される共通 API の開発・運用を行なっております。今回は、私が担当した API でメッセージキューとして利用した RabbitMQ を紹介させていただきたいと思います。 はじめにAPI 基盤グループで提供している API には、リクエストをリアルタイムに処理する必要がないものもあります。例えばメール配信 API や、投稿内容の有人監視 API などが挙げられます。 これらの非同期処理が可能な API では、大量のリクエストを受け取るためにメッセージキューを使用しています。 メッセージキューを使用した構成では、リクエストを受け取るプログラムが、受け取ったリクエストから生成したメッセージをキューに格納します。キューに格納されたメッセージは、メッセージを処理
RabbitMQ is a Free and Open Source Software. In addition, Broadcom offers an enterprise grade commercial offering with 24/7 expert support. Free and Open SourceRabbitMQ is licensed under the Mozilla Public License 2.0, while most client libraries are dual-licensed under the Apache Software License 2.0 and the Mozilla Public License 2.0. You have the freedom to use and modify RabbitMQ in a very bro
MQTT（旧称：MQ Telemetry Transport、Message Queuing Telemetry Transport）は、メッセージ指向ミドルウェアのアプリケーション層で使用される、TCP/IPによるPub/Sub型データ配信モデルの軽量なデータ配信プロトコルである。 MQTTのMQは、歴史的にはMQSeriesから来ているが、メッセージキューの機能は持たない[4]。 非力なデバイスやネットワークが不安定な場所でも動作しやすいように、メッセージ通信電文が軽量に設計されていることが特徴である。 Pub/Sub型メッセージング·パターンには、サーバとしてメッセージブローカー（英語版）が必要である。 サーバは、メッセージのトピックに基づいて、それを必要としているクライアントにメッセージを配布する。 仕様はロイヤリティフリーで公開されていて、現在の仕様は5となっている[5]。 19
RabbitMQ（ラビットエムキュー）は、Advanced Message Queuing Protocol (AMQP) を使用した、オープンソースのメッセージ指向ミドルウェアである。 RabbitMQ Serverは、Erlang言語で記述されており、クラスタリングとフェイルオーバーのためにOpen Telecom Platformフレームワークで構築されている。 当初の開発元はRabbit Technologies社であったが、2010年4月にSpringSource社に買収され[1][2]、その後SpringSource社がVMwareに買収された。そして、EMCとVMware、GEの出資で設立されたPivotal Software（英語版）社がRabbitMQの開発・サポートを行っていたが、2019年にVMware社がPivotal Softwareを吸収合併し、今はVMware
メッセージキュー（英: Message queue）は、プロセス間通信や同一プロセス内のスレッド間通信に使われるソフトウェアコンポーネントである。制御やデータを伝達するメッセージのキューである。 メッセージキューは非同期型通信プロトコルの一種を提供しており、送信側と受信側がメッセージキューに同時にやり取りしなくともよいことを意味する。キューに置かれるメッセージは、受信側がそれを取り出すまで格納されたままとなる。メッセージキューは大抵の場合、格納できる1つのメッセージの大きさや保持できるメッセージ数に上限を設けている。 メッセージキューには様々な実装がある。オペレーティングシステム内に実装される場合やアプリケーションソフトウェア内に実装される場合がある。それらのキューはそのシステムが必要とする用途でのみ使われる[1][2][3]。 その他の実装では、コンピュータ間のメッセージのやり取りに使わ
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
