リアクティブプログラミングにおけるPlay、Akka、Akka Streams
前回記事では、Lightbend Platformを構成する各プロダクトについて紹介しました。今回はLightbend Reactive Platformを構成するPlay framework、Akka、Akka Streamsについて、実際にサンプルを動かしながら解説します。 なお、本稿のサンプルプログラムを動かしたい場合、前回記事にセットアップ方法を記述してあるので、それを参考に環境を作成しておきましょう。 リアクティブプログラミングにおけるPlay framework ここではPlayのプロジェクトを作成し、ソースコードの内容について解説します。 sbtとは、Giter8とは なお前回記事では、「Activator ui」を使用してプロジェクトを作成しましたが、Activator uiはEOLを迎えることになっています。 現在は「sbt」「Giter8」の使用が推奨されているので、そ
リアクティブプログラミングにおけるPlay、Akka、Akka Streams
リアクティブプログラミングにおけるPlay、Akka、Akka Streams：リアクティブプログラミング超入門（3）（2/2 ページ） Reactive StreamsのAkka実装「Akka Streams」とは 現在のWebでは膨大な量のデータをリアルタイムでやりとりしています。こういったデータは普通にダウンロード／アップロードしていては時間がかかり過ぎてしまうので、ストリーム処理（無限に発生するデータを継続的に処理する仕組み）が必要になります。 例えば、下記などはストリームが妥当な処理方法です。 テラバイト級ファイルの処理（メモリに展開し切れない） 通信処理（処理が継続的に発生し続ける） Stream処理では、受信側（Subscriber）が処理しきれないデータを送信し続けるとバッファーがあふれてしまうため、送信側（Publisher）がデータを送り過ぎないようにする必要があります
Akka Streamsで実装するリアクティブストリーム
今回と次回の2回に分けて、Akka Streamsを使って実装するリアクティブストリームについて解説する。 はじめに 前回と前々回の2回で、Akkaでレジリエントなシステムを構築するためにAkka Clusterを使ってクラスタを組む方法を紹介しました。単に処理能力の向上を目的に並列化／分散化の手段としてAkkaを利用するだけでなく、障害に強く可用性の高いシステムを構築するための手段としても有効であることがおわかりいただけたでしょう。 今回と次回の2回に分けて、連続して発生し続けるデータを処理する「ストリーム処理」をAkkaで実現する方法を紹介します。Akkaではストリーム処理を実装する拡張機能として、「Akka Streams」が提供されています。Akka StreamsはJava 9の新機能として注目される「リアクティブストリーム」を実装したライブラリです。最初に リアクティブストリー
RPMとは？広告プラットフォームビジネスの中心にある最重要KPI
RPMは、もちろん、略語です。正しくは、Revenue per Milleと記載し、「1000ページインプレッションあたりの売上」あるいは「1000ページビューあたりの売上」という意味です。 私がこの言葉を初めて耳にしたのは、サンフランシスコのLookSmartとうい会社で働いているときで、1990年代後半だったと思います。ネットで検索すると、RPMの定義を記したページがいくつか見つかります。 最初にきいたときは、「はっ？何？」。「レベニュー・パー・何？？？」という感じでした。「Mille」がラテン語で1000を表すことも知らなかったですし、そもそも早口の英語だったこともあり、よく聞き取れなかった記憶があります。しかしながら、その後、この言葉には繰り返し接することになり、10年以上に渡って、これを中心に据えて仕事をすることになりました。というのも、その後に転職したOverture（現在、Y
Akkaで始める並行処理(1) - アクターモデルとAkkaの概要 - エンタープライズギークス (Enterprise Geeks)
概要 近年、コンピュータの CPU はマルチコアが当たり前になった。マルチコアを使うにはマルチスレッドプログラムを扱う必要がある。 また、アプリケーションでは Web サービスなど複数のネットワーク通信を使用することが多くなっている。通常ネットワーク通信は同期処理で行われる。複数のネットワーク通信を同期処理で行うと、通信結果の待ち時間が増えるため処理時間が延びてしまう。処理時間を短縮するためには、通信の非同期化や並列化が必要となる。 マルチコアを使いこなし、かつ複雑なアプリケーションを構築するためには、並行処理を簡単かつ効率的に記述する必要がある。 この連載では、アクターモデルによる並行処理ライブラリ Akka を通して、並行処理を実現する方法を紹介する。 今回はアクターモデルと Akka の概要について述べる。 アクターモデルとは 並列処理を効率的に実現する方法のひとつにアクターモデルが
第20章：Scalaでアクター！ - Qiita
ついに アクター について語る時がきました。 Scalaの醍醐味の一つです。 そして難しいです。。。 でも、アクターを使うと並列処理を扱うことが簡単になります。 ただアクターには色々な種類があるので、そこが簡単じゃないかも。。。 アクターの歴史 2.9のアクターは知らないんだけど、2.10からは標準のscala.actorパッケージが非推奨になっていて 今後削除されるみたいなんだ。 そして、今後はAkkaのアクターを使うことが推奨されている。 The Scala Actors API Akkaとは Typesafe社が開発していて、高い抽象度・並行・スケーラブルなアプリケーションを実装するためのScala・Javaのイベント駆動の分散並列型アプリケーションフレームワークです。 Typesafe社は、Scalaの生みの親Martin Oderskyの会社ですね。 アクターとは ところで アク
スレッドセーフな連想カウンタをリセットしたい人生だった - Qiita
とあるマイクロサービスにスレッドセーフな連想カウンタを仕込みたくなったので、ここのところ格闘していました。要件はこんな感じです。 リクエストごとに様々なキーのカウント値をインクリメントする 定期的に全キーのカウント値をログ出力して０にリセットする インクリメントされなくなったキーをメモリに保持しつづけない フレームワークとして使っている Finagle の mterics 機能を初めに検討したのですが、リセットする方法がなさそうだったのと、数十万個のキーを登録するようなものではなさそうだったので、自前で作ることにしました。 ということで Java のスレッドセーフな連想配列 ConcurrentHashMap のドキュメントを見てみると ConcurrentHashMapは、LongAdderの値を使用し、computeIfAbsentで初期化することにより、スケーラブルな頻度マップ(ヒス
NFTとブロックチェーンがアートやコレクションの未来である理由 | Coral Capital
最近、Non-Fungible Token（「非代替性トークン」：NFT）がメディアのトップニュースでよく取り上げられるようになりました。1番最近のニュースでは、Beepleとして知られるアーティストが、クリスティーズ・オークションハウスでNFT化した自身のデジタルアートを6,900万ドル（約75億円）で売却したことが報じられました。デジタル資産としては過去最高額である上に、250年もの歴史を誇る伝統的なオークションハウスがついにデジタルアートの競売をはじめたという点でも注目されています。しかも、実はBeepleの作品がクリスティーズ初のNFTではなく、昨年の10月にもBlock 21というNFTの競売が行われています。 NFTにあまり馴染みがない人のために説明すると、NFTとはブロックチェーン上に記録されるデジタル鑑定書のようなもので、デジタルアートだけではなく、音源や動画、記事、さらに
HTMLのtableにクラスを加えるだけで、グラフやチャートを簡単に実装できるCSSのフレームワーク -Charts.css
棒グラフや折れ線グラフ、どうやって実装していますか？ Charts.cssなら簡単です。データをtableタグで実装し、CSSのクラスをtableに加えるだけで横棒グラフ、棒線グラフ、折れ線グラフ、エリアグラフなどを簡単に実装できるCSSのフレームワークを紹介します。 HTMLは普通の表組みなのでアクセシブル、グラフやチャートはレスポンシブにも完全対応した優れものです。 Charts.css Charts.css -GitHub Charts.cssの特徴 Charts.cssのデモ Charts.cssの使い方 Charts.cssの特徴 Charts.cssはtableで実装した表組みにシンプルなCSSのクラスを加えるだけで、さまざまなグラフやチャートを実装できるフレームワークです。カスタマイズも簡単で、ユーティリティのクラスも豊富に用意されています。 HTMLとCSSだけで実装 セマ
なぜTwitterは低遅延のままスケールできたのか 秒間120万つぶやきを処理、Twitterシステムの“今” − ＠IT
ユーザー同士のつながりを元に時系列に140文字のメッセージを20個ほど表示する――。Twitterのサービスは、文字にしてしまうと実にシンプルだが、背後には非常に大きな技術的チャレンジが横たわっている。つぶやき数は月間10億件を突破、Twitterを流れるメッセージ数は秒間120万にも達し、ユーザー同士のつながりを表すソーシャル・グラフですらメモリに載る量を超えている。途方もないスケールのデータをつないでいるにも関わらず、0.1秒以下でWebページの表示を完了させなければならない。そのために各データストレージは1～5ms程度で応答しなければならない。 Twitterのリスト機能の実装でプロジェクトリーダーを務めたこともあるNick Kallen氏が来日し、2010年4月19日から2日間の予定で開催中の「QCon Tokyo 2010」で基調講演を行った。「Data Architecture
GitHub - charmbracelet/bubbletea: A powerful little TUI framework 🏗
The fun, functional and stateful way to build terminal apps. A Go framework based on The Elm Architecture. Bubble Tea is well-suited for simple and complex terminal applications, either inline, full-window, or a mix of both. Bubble Tea is in use in production and includes a number of features and performance optimizations we’ve added along the way. Among those is a standard framerate-based rendere
え、HTTPSの転送なのにファイルも暗号化するんですか？？？
TL;DR 基本的には二重での暗号は不要 ただし、転送後も暗号化したまま使うなら、転送前から暗号化するのは良い ルールXを無邪気に追加して不整合のあるセキュリティルールを作ってはいけない はじめに 社内のセキュリティルールやスタンダードを決めるときに、HTTPSなのにVPN必須になってたりファイル暗号も必須になってたりするケースたまに見ます。今回は、それは実際に必要なことなのか？ セキュリティ的に有効なのか？ という点で考察をしていきたいと思います。 背景 二重三重に暗号化しても性能ペナルティが無いなら「なんとなく安全そうだから」でOKにしてしまいがちなのですが、これはよく考える必要があります。 というのも 「ルールXを追加することで既存のルールAと不整合が出る」 ってことは割とよくあるからです。具体的には「SCPのファイル転送は（SCPのセキュリティに不備があった時の）安全性のためにファ
github actionsでunityビルドしてiOSとAndroidのストアに自動的に提出する - Qiita
こんにちは。virapture株式会社のもぐめっとです。 この記事を書いてるときは冬なんですけど、もう自分の写真がなさすぎて夏までさかのぼってしまいました。 本日はCI/CD with Unity, GitHub Actions, and Fastlaneという記事を参考にUnityでの自動ビルドとストア提出を作ってみたのでそのメモ書きを残しておきます。 概要 UnityにはUnity Cloud Buildという公式のCIがあるのですが、いかんせんfastlaneとの連携ができないので、証明書を引っ張ってきたり、ストアにアップロードというのができません。 そこで探してみたところ、GameCIが出しているunity-builderというgithub actionsを使ってビルドを行い、デプロイにはfastlaneを使用することでうまくできました。 このunity-builderが結構優秀で
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
AWS/アマゾン ウェブ サービス/クラウド on Twitter: "【新AWS Hands-on for Beginnersを公開！】AI/ML サービス入門ハンズオン https://t.co/RFO6zpMbKe 人気ハンズオンに新コンテンツが公開されました。「AI や機械学習をビジネスに活… https://t.co/gH1DpdBfvT"
./NyaHo.vrc🍤 on Twitter: "【固定】VRC向け便利アプリを作っています。 ・スクショ撮影時インスタンスへいた人の一覧を作成 https://t.co/BGJEAjTEgw ・現在地をTwitterへ投稿 https://t.co/K7gawxdN0f ・… https://t.co/OZF58qYyiu"
main()関数の前には何があるのか
まや🐤🔥FF14/スプラ/麻雀/テトリス＆雑談＆ASMRなど on Twitter: "めちゃくちゃ便利なChrome拡張機能を教えてもらっちゃ！１ボタンでタイムスタンプコメできる！ https://t.co/vjaz2PeIrz"
【解説】藤田晋が教えてくれた「投資で永遠に勝てない人の特徴」とは？【買いたいときに買うな】
T. Yamahara on Twitter: "昨日実施したAWS初心者向けのセキュリティグループのハンズオンでは配布資料がPDFでしたが、せっかくなのでZenn記事版も作成しました！ https://t.co/2VW4ngzMke"
あやと_zx14r on Twitter: "これのおかげでまたGoogleマップの地点からYahoo!のカーナビに目的地登録できるようになった！ めっちゃ便利🙏 「Google Maps の検索結果から Yahoo! カーナビで経路案内できる iOS ショートカット」を復… https://t.co/woZNotyDAc"
はる🐢Webコーダー on Twitter: "✅Chrome拡張機能「Clear Cache」 パートナーさんに教えていただいたツール① 設定にチェックをつけているときは、リロードのたびにキャッシュを削除してくれます✨便利😭 https://t.co/l5bzmpiV14"
Ｓ Ｈ Ｏ Ｄ Ａ Ｉ on Twitter: "裏日本は裏原宿である、と高木新平は言った｜佐々木俊尚 https://t.co/fVwWKx5Gy6 「つまり仲間たちがネットワーク化され、ネットワークが核となって、土地の人々や都会から来た人々はそのネットワークにぶら下がるという… https://t.co/iZ0jUYxSLb"