Akkaで始める並行処理(3) - アクターの基本 (Java編) - エンタープライズギークス (Enterprise Geeks)
前回の記事では、Scala による Akka の基本的なサンプルプログラムを紹介した。 Akka は Scala と Java それぞれに対応した API を提供している。 今回は、前回 Scala で作成したサンプルプログラムの Java 版を紹介する。 サンプルプログラムの全体構成を以下に再掲するが、詳細に関しては前回の記事を参照していただきたい。 今回のサンプルプログラムも、github で公開している。 子アクターの生成 Java 版では、アクターは、抽象クラスのUntypedActorを継承して定義する。 まず、子アクターの定義のうち、staticメンバーのメッセージオブジェクトの定義について示す。 // UntypedActor を継承 public class SubActor extends UntypedActor { // イミュータブルオブジェクトとしてメッセージクラ
リアクティブなマイクロサービスフレームワーク「Lagom」を試してみる - たけぞう瀕死ブログ
Lagomとは？ LagomはLightbend社（旧Typesafe社）がリリースした新しいマイクロサービス向けのフレームワークです。 www.lightbend.com 元々Scalaの開発元であったLightbend社が開発しているだけあり、PlayやAkka、sbtといったScalaベースの技術基盤上に構築されていますが、現時点ではJava向けのAPIのみ提供されているJava用のフレームワークとなります。*1 これまでもSpring Bootなど手軽に使えるAPIサーバ向けのWebフレームワークは存在したわけですが、Lagomは最初からリアクティブなマイクロサービスの構築を前提に設計されており、いわば「マイクロサービスネイティブ」とも呼ぶべきフレームワークになっています。 実際にLagomを使うかどうかはさておき、新しいコンセプトのフレームワークなので学ぶことも多いのではないかと
Akkaの分散されたアクター間でDBを使わずにデータを共有する方法 - Qiita
本記事は TIS Engineer Advent Calendar 2015 23日目の記事です。 はじめに Akka で分散システムを構築したときに、分散された複数のアクター間で常に更新されるデータを共有することを考えます。DBを使わずにやろうとすると、共有データを管理するためのアクターを1つ作っておき、常にそのアクターにデータの取得と更新を依頼するという方法が思いつきます。しかし、この方法ではデータを共有するためのアクターが単一障害点になってしまうということと、その部分のスケーラビリティを確保できないという問題があります。 耐障害性とスケーラビリティを確保したまま、Akkaのアクター間でデータを共有するにはどうすれば良いのでしょうか？こういうケースでは Akka の Distributed Data というモジュールが使えます。Distributed Data を使うと、DBを使わずに
JavaからAkkaを使う - Qiita
public class EchoActor extends UntypedActor { public EchoActor() { System.out.println("constructor"); } @Override public void onReceive(Object message) throws Exception { if (message instanceof String) { System.out.println("Got message. " + message); getSender().tell(message, getSender()); } else { System.out.println("Got unknown type message."); unhandled(message); } } } まずActorを作ります。akka.actorパッ
並行処理初心者のためのAkka入門
Concurrent programing explanation for akka beginers. 並行処理初心者のためのAkka入門 akka meetup 2014/09/28(日) http://connpass.com/event/8622/ このイベントの導入説明のために書かれました。 内容には、並行処理、アクターモデル、Akkaの機能の説明となっています。Read less
Java並行処理プログラミングを読んだ - だいたいよくわからないブログ
本の感想を書くことによりいい感じにブログネタを切らさないようにする生活(´･_･`) だいぶ前から読んでいた本をついに読み終わりました。 https://www.amazon.co.jp/Java%E4%B8%A6%E8%A1%8C%E5%87%A6%E7%90%86%E3%83%97%E3%83%AD%E3%82%B0%E3%83%A9%E3%83%9F%E3%83%B3%E3%82%B0-%E2%80%95%E3%81%9D%E3%81%AE%E3%80%8C%E5%9F%BA%E7%9B%A4%E3%80%8D%E3%81%A8%E3%80%8C%E6%9C%80%E6%96%B0API%E3%80%8D%E3%82%92%E7%A9%B6%E3%82%81%E3%82%8B%E2%80%95-Brian-Goetz/dp/4797337206 Scalaだとakkaとかあって、アク
『Javaではじめるakka入門』
はじめまして。 ブロググループ所属の見原と申します。 今回は先日担当した案件で利用した、akkaを紹介させていただきます。 はじめにakkaはtypesafeが提供する、イベント駆動の分散並列型アプリケーションフレームワークです。 並列処理が簡単に記述出来るほか、複数のマシンを用いた分散処理の実現、 「let it crash」という設計思想に基づいたロジックとリカバリ処理の分離などが特徴です。 akkaのサンプルはscalaが多いのですが、今回はjavaで説明していきます。 まずはMavenを利用したアプリケーションを作成します。 akkaを利用するため、以下をpom.xmlに記載します。 <repositories> <repository> <id>typesafe</id> <name>Typesafe Repository</name> <url>http://repo.type
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
