RxJava는 Reactive java에서 이름을 따왔다.
Reactive programming(리액티브 프로그래밍) 패러다임을 자바에서 구현한 프로그래밍 라이브러리이다.
프로그래밍 패러다임에는 여러가지가 있는데 OOP(객체지향), Function(함수), Imperative(명령형) 등이 있다.
대체로 많은 프로그램들이 명령형 프로그래밍이라고 할 수 있고 여기에는 자바, 파이썬, C, Node.js등도 포함 되어 있다.
특정 언어라고 해서 한가지 프로그래밍 패러다임만 사용하는건 아니지만 특정 목적에 맞게 설계된 언어들이 있다.
여기에서 '패러다임(paradigm)'은 방법론 정도로 보면 된다.
여러가지 언어 중에서 자바는 OOP(Object Oriented Programming)라고 해서 객체지향형 프로그래밍의 대표 언어이고 Functional Programming(펑셔널 프로그래밍)을 대표하는건 파이썬, node.js등이라고 할 수 있다. 자바로 Reactive Programming을 해야할 일이 생겨서 이 라이브러리가 등장 하였다. 그리고 자바가 버젼이 올라가면서 여러가지 요즘 트렌드에 맞게 기술들이 추가 되어서 OOP기반이었던 자바가 Functional, Reactive 등의 프로그래밍 방법론으로도 개발이 가능하게 되었다.
리액티브란 외부에서 자극이 오고 그에 대해 반응 한다는 뜻이다.
아래는 rxJava로 hello를 출력한 코드이다.
1 2 3 4 5 6 7 8 9 10 11 12 13 | import io.reactivex.Observable; public class FirstExample { public void emit(){ Observable.just("hello", "rxjava2!!") .subscribe(System.out::println); } public static void main(String[] args) { FirstExample firstExample = new FirstExample(); firstExample.emit(); } } | cs |
Observer라는 것을 사용하는게 RxJava이다.
Function
Function은 쉽게 이야기 해서 제네릭으로 <기존타입, 리턴타입>을 받아서 .apply()를 하면 기존 타입의 연산 결과를 결과 타입으로 반환을 해준다.
소스코드는 아래와 같다.
1 2 3 4 5 6 7 8 9 10 | import java.util.function.Function; public class FunctionExample { public static void main(String[] args) { Function<String, Integer> function = str -> Integer.parseInt(str); Integer integer = function.apply("10"); System.out.println(integer); } } | cs |
gradle로 빌드한 소스코드는 아래 repository에 올려 놓았다.
https://github.com/Kyeongrok/rxjava_helloworld/
Consumer(컨슈머)
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 | Observable<Integer> source = Observable.create((ObservableEmitter<Integer> emitter) -> { emitter.onNext(100); emitter.onNext(200); emitter.onNext(300); emitter.onComplete(); }); // 람다 + 메소드 레퍼런스 source.subscribe(System.out::println); // 그냥 코드 source.subscribe(new Consumer<Integer>() { @Override public void accept(Integer integer) throws Exception { System.out.println("result : " + integer); } }); | cs |
컨슈머는 값을 받는 익명 void함수다.
위 코드 10번줄 처럼 한줄이면 끝나는 코드를 그냥 쓸려면 13~18 이렇게 길게 써야 한다.
'프로그래밍 > JAVA ' 카테고리의 다른 글
| java paging class (자바 페이징 클래스) (0) | 2016.08.19 |
|---|
낭만가을