Reactive Streams 入門 #jjug
2015/06/24 JJUG ナイトセミナー 「Reactive Streams特集」 by @okapies https://jjug.doorkeeper.jp/events/26547 補足記事: http://okapies.hateblo.jp/entry/2015/06/26/024505
2015/06/24 JJUG ナイトセミナー 「Reactive Streams特集」 by @okapies https://jjug.doorkeeper.jp/events/26547 補足記事: http://okapies.hateblo.jp/entry/2015/06/26/024505
非同期ストリーム処理の標準化を目指す "Reactive Streams" とは - Okapies' Archive
TL でこんなのが流れてたので少し調べてみた。 Learn about the Reactive Streams initiative & how we're supporting a standard for asynch stream processing on the JVM http://t.co/5wUF0PjTBe— Twitter Engineering (@TwitterEng) 2014, 4月 17 Reactive Streams って？ Reactive Streams ”JVM 上でのノンブロッキングなバックプレッシャーを持つ非同期ストリーム処理の標準の提案”（公式サイトより）。 ざっくり言うと、既にある JVM ベースの様々な非同期ストリーム処理フレームワーク実装の共通部分を括りだして API 化、SPI 化しようというもの。最終的には JSR での標準化を目指
Reactive Streamsというのはノンブロッキングなback pressure可能な非同期ストリーム処理の標準的な仕様を提供しようというもので、実装としてはAkka Streams、RxJava、Reactor Composable、Ratpackなどがあります。 Reactive StreamsについてはAkkaのコミッタであるKonrad Malawskiさんの以下のスライドがとてもわかりやすいです。 2014 akka-streams-tokyo-japanese from Konrad Malawski ストリーム処理（というか非同期メッセージング全般に言えることですが）では受信側の処理能力を超えるデータを送信し続けるといずれキャパシティを超えてオーバーフローが発生してしまうため、送信側に比べて受信側の処理能力が低い場合は送信側が手加減してデータを送信する必要があります。な
JJUG ナイトセミナーで Reactive Streams について発表しました - Okapies' Archive
6月24日の JJUG ナイトセミナーで「Reactive Streams 入門」のタイトルで発表させて頂きました。最近話題の Reactive Programming、気がついたら一万人以上が署名している Reactive Manifesto、そして Java 9 で標準化という話が進んでいる Reactive Streams をまとめて俯瞰してみました、という感じの内容になっています。 かなり戦々恐々だったのですが、思いのほかご好評をいただきとてもとてもほっとしています。発表の機会を与えて下さった JJUG スタッフの皆様、会場をご提供頂いたオラクル様、発表を聴いてくださった参加者の方々、ありがとうございました。 発表でも触れましたが、"Reactive" という概念が何を指すかについては大きな混乱があり、様々な論者が異なる定義を提唱しているのが現状です。一方で、そうした定義の背景には
6/24 に開催された 【東京】JJUG ナイトセミナー 「Reactive Streams特集」 に参加してきました。これはその感想エントリになります。 ここ最近は勉強会に参加しても、それについてのエントリを書くのをサボってましたが (^^;; 、今回の勉強会は自分にとって非常に考えるところが多かった内容でしたので、ちょっと思ったところをだらだらっと並べてみました。 勉強会について 勉強会の内容は 2 部構成になっていました。前半は岡本雄太 (id:okapies) さんによる「Reactive Streams 入門」で、Reactive Streams について、似た言葉である Reactive Programming や Reactive Manifesto と併せて、それぞれの概念の違い、関わりについて分かり易く説明してもらいました。 https://speakerdeck.com
In Play meetup 2 (2015/07/05) by @okapies https://playframeworkja.doorkeeper.jp/events/27023 ※ Reactive Streams 入門 (https://speakerdeck.com/okapies/reactive-streams-ru-men-number-jjug) の補足スライドです。
12のソフトウェア・アーキテクチャの落とし穴とその避け方 成功するソフトウェアアーキテクチャを開発するのはシンプルだが、簡単ではない。QARを理解し、QARを最大限に満たすトレードオフを理解し、実行するには、洞察力と経験が必要であり、その多くはアーキテクチャ自体の実験を繰り返すことで集めなければならない。プロセス自体は単純だが、考慮すべきトレードオフはしばしば難しく、簡単な答えはめったにない。
Reactive Streamsを使ってみよう
Task scheduling can be boring, but not with Symfony Scheduler
Vert.xからみたReactive Streams
GitHub - line/armeria: Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring B
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session. Dismiss alert
Java SE 9の新機能としてはあまり目立ってはいませんが、非同期処理ライブラリの「Concurrency Utilities」にも新しい機能が導入されています。Concurrency Utilitesの新機能はJEP 266 More Concurrency Updateで提案されています。導入される主な機能は以下の2つです。 Reactive Streamsの導入 CompletableFutureクラスの拡充 前者のReactive Streamsは新しい概念の導入になります。一方、後者のCompletableFutureクラスは様々なメソッドが追加されているものの、基本的な使い方はこれまでと同じです。そこで、今回は前者のReactive Streamsについて紹介していきます。 Reactive Streamsは、非同期ストリーム処理を実現するため、Reactive Stream
2018-05-26に行われた「JJUG CCC 2018 Spring」で発表した時の資料です。
"Reactive Streams" の実装はどうなっているの？ - Taste of Tech Topics
こんにちは。@kimutanskです。 夏の日差しが日に日に増し、セミも盛んに鳴きはじめましたが、皆さん夏バテなどされていませんか？ さて、今回の内容は、非同期ストリーム処理界隈で注目の「Reactive Streams」です。 先月のJJUGナイトセミナーでも取り上げられており、私は残念ながら参加はできなかったのですが 後から資料を読んで勉強させていただきました。jjug.doorkeeper.jp 1. Reactive Streamsとは何か？ Reactive Streamsとは、「JVM 上でのノンブロッキングなバックプレッシャーを持つ非同期ストリーム処理の標準」で、 様々な非同期ストリーム処理のインタフェースを共通化して標準的に扱えるようにしようというものです。 分散環境での非同期ストリーム処理においては、 「上流のコンポーネント群の方が処理能力が高く、下流のコンポーネント群が
Play All Day: Reactive Streams and Play 3.0 – Free E-Books | Typesafe
Akka Toolkit for building API's, microservices, and data streams.
ScalikeJDBCをAkka StreamsのSourceにする (ScalikeJDBC + Reactive Streams) - yoskhdia’s diary
Scala Advent Calendar 2016の15日目です。 バッチアプリケーションを作ることになったので、Akka Streamsを使おうかと考えました。 Slickだと標準でstreamメソッドが用意されているため、Akka Streamsとも連携させやすいですが、ScalikeJDBCが学習コストが低くて素敵だったので、コレをAkka Streamsに組み込めないか試したエントリです。 DBはMySQLを使う前提ですので、ご注意ください。 （一部Postgresも引き合いにしてますが、OracleやSQL Server等は調べてません。） TL;DR github.com 2017/05/20 追記 ScalikeJDBC 3.0に公式に取り込まれました。 github.com JDBCブロッキング問題 現在、JDBCは同期インタフェースしか提供されていません。 asyncな
[Japanese] How Reactive Streams and Akka Streams change the JVM Ecosystem @ Reactive Shinjuku
[Japanese] How Reactive Streams and Akka Streams change the JVM Ecosystem @ Reactive Shinjuku
![[Japanese] How Reactive Streams and Akka Streams change the JVM Ecosystem @ Reactive Shinjuku](https://cdn-ak-scissors.b.st-hatena.com/image/square/df60d162ee2dc3de735ae998b9961b4ac8820ab9/height=288;version=1;width=512/https%3A%2F%2Fcdn.slidesharecdn.com%2Fss_thumbnails%2F2016-tokyo-akka-streams-reactive-streams-160208101926-thumbnail.jpg%3Fwidth%3D640%26height%3D640%26fit%3Dbounds)
こんにちは。 最近気になっていた「Reactive Streams」について試してみました。 1. Reactive Streamsとは？ 少し前にReactive Streamという情報がWebに流れていました。 Reactive Streams 何かというと、 "Reactive Streams is an initiative to provide a standard for asynchronous stream processing with non-blocking back pressure on the JVM." つまり、 JVM上で動作するバックプレッシャー機能を保持するノンブロッキングな非同期ストリーム処理標準化のための提案 ということになります。 実際どういう意図で始まり、概要がどういうものか、についてはOkapiesさんがまとめています。 非同期ストリーム処理の
CodeZine編集部では、現場で活躍するデベロッパーをスターにするためのカンファレンス「Developers Summit」や、エンジニアの生きざまをブーストするためのイベント「Developers Boost」など、さまざまなカンファレンスを企画・運営しています。
RxJava 2.xで導入されたReactive Streams
対象読者 Java経験者（初心者可） RxJava未経験者 リアクティブプログラミング未経験者 ※ただし、前回までの連載を読んでいる前提です。 2.xへのバージョンアップについて RxJavaのバージョンが1.xから2.xに上がった背景にReactive Streamsの適用があります。Reactive Streamsとはどのライブラリやフレームワークを使っているのかに関係なく、データストリームを非同期で扱えるようにするための共通の仕組みを提供するもので、そのためのインタフェースを提供しています。 Reactive Streams ちなみにReactive Streamsが提供するのはインタフェースのみで、実装は各ライブラリやフレームワークに委ねられます。 RxJavaの今回のバージョンアップでは、このReactive Streamsの実装とともに、まったく新しく実装しなおすことでパフォー
Slick 3: Reactive Streams for Asynchronous Database Access in Scala
The InfoQ Trends Reports 2023 eMag The InfoQ trends reports provide a snapshot of emerging software technology and ideas. We create the reports and accompanying graphs to aid software engineers and architects in evaluating what trends may help them design and build better software. Our editorial teams also use them to help focus our content on innovator and early adopter trends.
JJUG ナイトセミナー「Reactive Streams特集」に行ってきた #JJUG - mike-neckのブログ
眠いし、最近Java書いてないし、非同期とかあまりつかってないので、あまりピンとこない分野ですので、雑に書きます。 で、件の勉強会に行きました。 jjug.doorkeeper.jp 感想概要 Reactiveホゲホゲについては、まあ、データが来たら、変換して、IOを発生させるくらいの認識しかなかったので、とっかかりが欲しかったので申し込みましたが、如何せん非同期とかをうまく組み合わせてレスポンスを作るなどの(Play!Scalaでよくあるような非同期プログラミング)については全然扱ったことがなかったので、結構内容を把握するのが辛かったです。 発表資料 こちらにあるようです。 speakerdeck.com Reactive Streamsを使ってみよう Reactive Streams 入門 前者の資料。@okapiesによる発表。 資料作りに気合入って、資料は結構飛ばし飛ばしで発表され
Springone2gx 2014 Reactive Streams and Reactor
A session about the Reactor story with Reactive Streams pragmatic specification. Talk recorded at SpringOne2GX 2014 Dallas.
GitHub - reactive-streams/reactive-streams-jvm: Reactive Streams Specification for the JVM
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session. Dismiss alert
A Deeper Look Into Reactive Streams with Akka Streams 1.0 and Slick 3.0
Reactive Streams 1.0.0 is now live, and so are our implementations in Akka Streams 1.0 and Slick 3.0. Reactive Streams is an engineering collaboration between heavy hitters in the area of streaming data on the JVM. With the Reactive Streams Special Interest Group, we set out to standardize a common ground for achieving statically-typed, high-performance, low latency, asynchronous streams of data w
Reactive Streams: Handling Data-Flow the Reactive Way
Building on the success of Reactive Extensions—first in Rx.NET and now in RxJava—we are taking Observers and Observables to the next level: by adding the capability of handling back-pressure between asynchronous execution stages we enable the distribution of stream processing across a cluster of potentially thousands of nodes. The project defines the common interfaces for interoperable stream impl
An Update On The Release Of Reactive Streams 1.0.1 And What's In JDK 9 | @lightbend
Reactive Streams is an initiative to provide a standard for asynchronous stream processing with non-blocking back pressure. Ever since Reactive Streams 1.0.0 was released at the end of April 2015, I’ve been wondering when—if ever—I’d write another announcement blog post for a new version on Reactive Streams. For the most part, I’ve been extremely curious to see what would happen: would there be an
GitHub - jaredly/rxvision: visualizer debugger for reactive streams
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session. Dismiss alert
Photo by Darron BirgenheierReactive Extensions¹ (ReactiveX or Rx for short) were initially created by Erik Meijer for .NET and were revealed to the public in 2010. It was a new approach to API for asynchronous data streams that generalized observer pattern with callbacks for emitted elements (onNext), stream completion (onCompleted), and error (onError), and introduced stream-processing operators
Reactive Queue with Akka Reactive Streams | Adam Warski: programming articles & videos
Update 15/09/2014: introduced API changes from akka-streams 0.7. Update 30/10/2014: introduced API changes from akka-streams 0.9. Update 15/12/2014: introduced API changes from akka-streams 1.0-M1. Reactive streams is a recently announced initiative to create a standard for asynchronous stream processing with built-in back-pressure, on the JVM. The working group is formed by companies such as Type
LINE株式会社は、2023年10月1日にLINEヤフー株式会社になりました。LINEヤフー株式会社の新しいブログはこちらです。 LINEヤフー Tech Blog Reactive Streamsとは？ LINE PlusでオープンソースソフトウェアのArmeriaとCentral Dogmaを開発しているUM IKHUNです。私はReactive Streamsの概念と、Reactive Streamsをオープンソースの非同期HTTP/2、RPC、RESTクライアント／サーバーライブラリーであるArmeriaで使用する方法について紹介したいと思います。今回の記事では、まずReactive Streamsの概念について解説します。 Reactive Streamsは、公式ホームページであるreactive-streams.orgで以下のように定義しています。 Reactive Strea
Designing for Distributed Systems with Reactor and Reactive Streams
Designing for Distributed Systems with Reactor and Reactive Streams
http://www.zhaojunlucky.com/architecture/what-is-reactive-systems/より引用 はじめに JJUG ナイトセミナー 「Reactive Streams特集」に参加してきました。 本記事では実際に参加して感じたこと、学んだことをメモがてらまとめようと思います。 今回参加の目的としては ・自分の中でバズワード化している「リアクティブ」な用語が分からない ・概念はどんなものか？ ・ただのObserverパターンじゃないの？ ・ただのFuture/Promiseじゃないの？ ・ただのデータバインディングじゃないの？ ・Stream APIっぽい関数型パラダイム的な何かじゃないの？ というところの曖昧さの整理とか勉強のためでした。 すでに色んな方がレポートを書いてます。みんな仕事が早いですね(^^; ・JJUGのReactive Stre
The InfoQ Trends Reports 2023 eMag The InfoQ trends reports provide a snapshot of emerging software technology and ideas. We create the reports and accompanying graphs to aid software engineers and architects in evaluating what trends may help them design and build better software. Our editorial teams also use them to help focus our content on innovator and early adopter trends.
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Reactive Streamsとは？ - たけぞう瀕死ブログ
JJUG ナイトセミナー 「Reactive Streams特集」の感想 - AOEの日記
Play and Reactive Streams #play_ja
Slick 3: Scalaで非同期データアクセスを実現するReactive Streams
Introduction to Reactor & Reactive Streams
Java SE 9の非同期処理ライブラリ、新概念の「Reactive Streams」を学ぶ
Apache Kafkaとストリーム処理/Reactive Streams
Akka StreamsによるReactive Streamsって？ - 夢とガラクタの集積場
非同期ストリーム処理の標準「Reactive Streams 1.0.0」がリリース
Reactive Streams and Kotlin Flows
Let’s play Reactive Streams with Armeria vol.1
JJUG ナイトセミナー 「Reactive Streams特集」に行ってきました #jjug
Reactive Streams Releases First Stable Version for JVM