RxJava 2とArmeriaでマイクロサービスを非同期化してみた : LINE Engineering Blog
こんにちは、LINEメッセンジャーのサーバーサイド開発チームに所属してスタンプや着せかえに関連する開発を担当している川田（@hktechno）です。この記事はLINE Advent Calendar 2017の2日目の記事です。 私が所属しているチームは、数年前からマイクロサービス化されたサービスのRPC（Remote Procedure Call）やDBアクセスを非同期化し、レイテンシの削減やサーバーリソースの省力化に勤しんできました。最近は、LINE内部で開発しているRPCサーバーArmeriaとRxJava 2を使って、“Javaにしては”なかなかイケている内部構成になってきました。この記事では、そんな私達のチームで開発しているスタンプ・着せかえ関連サーバーの裏側についてご紹介したいと思います。 LINE Shopにおけるマイクロサービス 一言でLINEといっても、LINEと名前のつ
RxJavaのレシピ：Androidのイベントをストリームに変換する | POSTD
問題 まず、これから解決していく問題を先に述べます。 イベント（例えばOSの通知やBluetoothの状態）を受け取る部分がアプリ内に複数あり、各部分に関係がある時にのみその情報を受け取りたい場合を想像してみてください。 アプリの最初のクライアントが関心を持った時にのみイベントリスナーが登録され、誰も関心を持たなくなれば、すぐに登録を解除する必要がある。 新しいクライアントがイベントを購読する際、既存のクライアントに送信済みの前回のイベントを新しいクライアントがすぐに受け取れるようにして、全クライアントが常に同期するようにする。 今回の記事では、RxJavaの様々なコンポーネントを組み合わせることで、この問題を解決する道を探ろうと思います。本題に入る前に、 Subject や Replay 、そして Connectable Observables などのコンセプトを理解しておいてください。
RxJava + Flux (+ Kotlin)によるAndroidアプリ設計 - Qiita
Introduction Androidにとってアプリ設計は永遠の課題だと思います。 Activityが独特のライフサイクルを持っているのがさらに課題を複雑化します。 設計についてはMVCやMVP、MVVM、Clean-Architecture、DDDなどが最近の主流でしょうか。 上記にあがった設計手法に関しては素晴らしい記事がいくつもあるのでとても参考になると思います。 AndroidではMVCよりMVPの方がいいかもしれない http://konifar.hatenablog.com/entry/2015/04/17/010606 [ Android ] - これからの「設計」の話をしよう https://tech.recruit-mp.co.jp/mobile/android-architecture/ AndroidオールスターズでClean Architectureについて発表し
RxJavaのイベントリソースの解放とisUnsubscribed()の関係について
いまいち釈然としないものの、unsubscribeのタイミングでcancel処理をしたりイベントを投げるまえにisUnsubscribed()でチェックするのがセオリーっぽい雰囲気？まだ納得しきっていないのであとで自分でも検証してみる。
詳解RxJava2：Backpressureで流速制御 - Qiita
追記：記事のタイトルがRxJava 2.xを対象にしているように見えますが、正確には詳解RxJava 1.xの2本目です＞＜ 謝辞：チームでは本当に自由にRxJavaを使わせてもらっていて、今回の記事の内容も実際にアプリでReactiveな表示更新ロジックを書こうとして習得したものです。 この記事ではRxJavaのBackpressureの仕組みについて説明しつつ、Backpressureを使って問題をうまく解決できるパターンを紹介します。深夜テンションで一部お見苦しい点がございますがお許しください。 これまでのあらすじ RxJavaに3日で入門し、Androidアプリのリスト操作、非同期処理、変更通知の課題を解決した話 http://qiita.com/yuya_presto/items/152fa80d073d865cfc90 詳解RxJava1：Scheduler、非同期処理、sub
RxJavaでEventBusを作った - Qiita
経緯 以前イベントバスとしてOttoを使用していたが、RxJavaを使ったほうがよい実装ができるので、Deprecatedとなったようだ。 以前、KotlinでRxを使ったイベントバスを作成していたので、Java化してライブラリとして公開してみることにした。 RxEventBus 簡単な使用方法はREADMEを参照。 特徴 イベントクラスはEventクラスを継承する必要がある。 ハンドラ登録はRxEventBus#subscribe()で行う。 RxEventBus#subscribe()の戻り値であるSubscriptionに対してunsubscribe()することで、ハンドリングをやめる。 第3パラメーターにSchedulerを渡すことで、第2パラメーターのラムダの実行スレッドを変更できる。 イベント送信はRxEventBus#post()で行う。 イベントが一度もハンドリングされなか
RxJava は Subscriber を中心に捉えると理解しやすいんじゃないかという話 - hydrakecat’s blog
これは RxJava Advent Calendar 2015 の第22日目の記事です。昨日は kazy さんによる RxJava 2.xについて でした。 この記事では、 RxJava を理解するために自分が RxJava をどのように捉えているか、という話をします。なお、自分は ReactiveX や Reactive Functional Programming について詳しいわけではないので、その方面の理解の助けになるものではありません。どちらかといえば、RxJava という特定のライブラリをこう理解しておけば全体の挙動を把握しやすいのではないか、という生活の知恵のようなものになります。RxJS や他のライブラリではまた異なる実装かもしれませんのでご留意ください。 RxJava は非常に強力でよく考えられたものですが、ソースを見て挙動が直感的に分かるとは言えないライブラリです。本稿
RxJavaのミニマム実装でScheduler周りを書いてみるゾ！ - Islands in the byte stream
RxJava Advent Calendar 2015 の23日分です。 はい、さっそくですがRxInTheBoxにSchedulerを実装しました。 observeOn() と subscribeOn() が本家RxJava同様の振る舞いをします。 add subscribeOn() and observeOn() to RxInTheBox by gfx · Pull Request #2 · gfx/RxInTheBox · GitHub これは何 半年ほど前に社内勉強会のネタとしてRxJavaのミニマムな実装をしてみました。それがRxInTheBoxで、主な実装が約20行です。 RxJava的なものを最小限に実装してコンポーネントの関係を理解する - Qiita そして時は流れ、subscribeOn()とobserveOn()の挙動にハマったりしながらなんとかRxJavaをそれな
RxJavaのsubscribeOn()とobserveOn()を使いこなしたい - Islands in the byte stream
RxJava Advent Calendar 2015 の 12月12日分です。 RxJavaのSchedulersは、RxJavaのコールバックの実行スレッドを制御するためのコンポーネントです。 恥ずかしながら、最近まで subscribeOn() と observeOn() の使い方を理解していませんでした。よって本稿では、 subscribeOn() と observeOn() の現状の私の理解したところを書きます。 SchedulersとsubscribeOn() / observeOn() RxJavaのSchedulersまわり一番難しいのは subscribeOn() と observeOn() がどう違うのか、という点だと思います。 これは実用的には以下のように考えるとよいかと思います。 subscribeOn() は Observable.OnSubscribe#call
詳解RxJava：Scheduler、非同期処理、subscribe/unsubscribe - Qiita
RxJavaで聞かれたり悩んだり、罠ったことを書き足していく予定です。 こちらもどうぞ: http://qiita.com/yuya_presto/items/152fa80d073d865cfc90 Scheduler、非同期処理 非同期でやるには？どこからが非同期で実行されるの？ Observableの実装や叩いたOperator（map()やfilter()などのメソッド）によりますが、基本的に現在のスレッド（subscribe()を呼び出したスレッド）で「同期的に」実行されます。 ドキュメントに Scheduler: This version of XXX does not operate by default on a particular Scheduler. と書かれているものは、現在のスレッドで実行されます from(): 現在のスレッドで実行されます Subject: o
イベントバスとリアクティブプログラミングの違いについて - torutkのブログ
GUIを持つアプリケーションの設計では、ソフトウェアアーキテクチャパターン*1としてMVCパターンを使用し、MVCパターンを実現する上で、Modelの変更をViewやControllerへ通知する仕組みにデザインパターン*2としてObserverパターンを使用するのが古典的定番です。 ところが、Observerパターンを使ったModelには、Observableのリストを管理し、状態変更の際にリストに登録されるObserbable全てに通知する仕組みを実装する必要があり、結構な作業となります*3。 このModelからの通知をObserverパターンで実現する代わりに、イベントバスを使って実現すると、Modelの実装を簡潔にすることができます。Java SEではあまり事例を見かけませんが、Androidでは割とメジャーに使われているようです。 先日、Androidでイベントバスのライブラリを
RxJavaに3日で入門し、Androidアプリのリスト操作、非同期処理、変更通知の課題を解決した話 - Qiita
なんでこの記事書いたのか 今開発中のプロダクトにおいて、RxJavaの導入をやってみたので、実際に使った箇所とその例、調べないとわからなかったことを載せておきました。 そう（retrolambdaのためにjdk8を投入）までして導入したかったメリットを話してくれ、サンプルコードがないとわからん、といった声を頂いているので、実際に何が解決されたのか、どんなコードで解決したのかということと、そのために勉強しなくてはならなかった点について書いています。 （追記）警告：差分作ってコード上では解決したんですが、この差分まだ「リリース」したわけじゃないので、その点だけご注意くださいｍｍ 続報あり次第追記します。 追記：リリースして安定運用しています！最近まで監視に難がありましたがそれも修正しました。この記事の監視スニペットも更新済みです！ なぜRxJavaを導入したのか 次の課題をまとめて解決できるの
7つのサンプルプログラムで学ぶRxJavaの挙動 - クックパッド開発者ブログ
会員事業部の山下(@tomorrowkey)です。 RxJavaが流行ってますね。最近Android版クックパッドでもRxJavaが導入されました。この記事は私がRxJavaを使うにあたって検証用のテストコードを書いたものをベースに、RxJavaの挙動をみなさんに紹介したいと思います。 目次 リスト操作でおさらいする基本的なRxJavaの使い方 Observable Operator Observer / Subscribe 実行順序を確認するサンプルプログラム 7つのサンプルプログラム リスト操作でおさらいする基本的なRxJavaの使い方 RxJavaはAPIアクセスやイベントトリガーやリスト処理などを多岐にわたる処理に使うことができます。このエントリでは初学者に一番分かりやすいリストの処理を例に解説します。 これは1から10までの値を渡し、偶数だけにフィルタリングしたうえ、値を10倍に
manbetx·万博�(中国)有限公司
对不起，您请求的页面不存在、或已被删除、或暂时不可用 请点击以下链接继续浏览网页 》查看产品展示 》返回网站首页 manbetx·万博(中国)有限公司
RxJava学習のベストプラクティスっぽいもの
KubeCon + CloudNativeCon Europe 2025 Recap: The GPUs on the Bus Go 'Round and 'Round / Kubernetes Meetup Tokyo #70
よくわかんないけど最近つくってるゲームで RxJava つかってみてる
社内RxJava勉強会で発表した時の資料です。
RxJavaのObservable<T>でOptional<T>を代行する - visible true
RxAndroidとRetrolambdaで大体Java8をAndroidに持ち込むでOptionalは使えず、良さ気なライブラリは見当たらないと書いたのだけど、そもそもRxJavaのObservable<T>はOptional<T>と同等の機能を持ってるっぽくない？という事に気がついて試してみたらOptional<T>でした。とは言え若干違う点や面倒な点もあるので完全に置き換えられるって感じでもない気がしますが十分な気もします。そもそもAndroidがさっさとJava8をサポートしてくれたらいいんです。 参考 Optionalの実装の参考 GC: Optional - java.util.Optional (.java) - GrepCode Class Source Optionalのjavadoc Optional (Java Platform SE 8 ) Optional.of(
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
The State of Managing State with RxJava (Devoxx US 2017)
初心者のための RxJava
Reactive とは何か？ #reactive_shinjuku
