Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commite5f1ff1

Browse files
committed
Merge pull requestiluwatar#242 from iluwatar/Reactor
Reactoriluwatar#74 implemented using Java NIO framework.
2 parents2dc98f6 +dbc2aca commite5f1ff1

17 files changed

+1459
-2
lines changed

‎pom.xml

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,12 +73,13 @@
7373
<module>front-controller</module>
7474
<module>repository</module>
7575
<module>async-method-invocation</module>
76-
<module>business-delegate</module>
77-
<module>half-sync-half-async</module>
76+
<module>business-delegate</module>
77+
<module>half-sync-half-async</module>
7878
<module>step-builder</module>
7979
<module>layers</module>
8080
<module>message-channel</module>
8181
<module>fluentinterface</module>
82+
<module>reactor</module>
8283
</modules>
8384

8485
<dependencyManagement>

‎reactor/etc/reactor.png

121 KB
Loading

‎reactor/etc/reactor.ucls

Lines changed: 207 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,207 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<class-diagramversion="1.1.8"icons="true"automaticImage="PNG"always-add-relationships="false"generalizations="true"
3+
realizations="true"associations="true"dependencies="true"nesting-relationships="true">
4+
<classid="1"language="java"name="java.nio.channels.Selector"project="abstract-factory"
5+
file="/opt/Softwares/Eclipses/MARS/eclipse/jre/lib/rt.jar"binary="true"corner="BOTTOM_RIGHT">
6+
<positionheight="224"width="188"x="1120"y="-50"/>
7+
<displayautosize="false"stereotype="true"package="true"initial-value="false"signature="true"
8+
sort-features="false"accessors="true"visibility="true">
9+
<attributespublic="true"package="true"protected="true"private="true"static="true"/>
10+
<operationspublic="true"package="true"protected="false"private="true"static="true"/>
11+
</display>
12+
</class>
13+
<classid="2"language="java"name="com.iluwatar.reactor.framework.NioReactor"project="reactor"
14+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java"binary="false"corner="BOTTOM_RIGHT">
15+
<positionheight="-1"width="-1"x="760"y="19"/>
16+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
17+
sort-features="false"accessors="true"visibility="true">
18+
<attributespublic="true"package="true"protected="true"private="false"static="true"/>
19+
<operationspublic="true"package="true"protected="true"private="false"static="true"/>
20+
</display>
21+
</class>
22+
<interfaceid="3"language="java"name="com.iluwatar.reactor.framework.Dispatcher"project="reactor"
23+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/Dispatcher.java"binary="false"corner="BOTTOM_RIGHT">
24+
<positionheight="-1"width="-1"x="569"y="279"/>
25+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
26+
sort-features="false"accessors="true"visibility="true">
27+
<attributespublic="true"package="true"protected="true"private="true"static="true"/>
28+
<operationspublic="true"package="true"protected="true"private="true"static="true"/>
29+
</display>
30+
</interface>
31+
<classid="4"language="java"name="com.iluwatar.reactor.framework.SameThreadDispatcher"project="reactor"
32+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/SameThreadDispatcher.java"binary="false"
33+
corner="BOTTOM_RIGHT">
34+
<positionheight="-1"width="-1"x="291"y="562"/>
35+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
36+
sort-features="false"accessors="true"visibility="true">
37+
<attributespublic="true"package="true"protected="true"private="true"static="true"/>
38+
<operationspublic="true"package="true"protected="true"private="true"static="true"/>
39+
</display>
40+
</class>
41+
<classid="5"language="java"name="com.iluwatar.reactor.framework.ThreadPoolDispatcher"project="reactor"
42+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/ThreadPoolDispatcher.java"binary="false"
43+
corner="BOTTOM_RIGHT">
44+
<positionheight="115"width="356"x="341"y="375"/>
45+
<displayautosize="false"stereotype="true"package="true"initial-value="false"signature="true"
46+
sort-features="false"accessors="true"visibility="true">
47+
<attributespublic="true"package="true"protected="true"private="false"static="true"/>
48+
<operationspublic="true"package="true"protected="true"private="true"static="true"/>
49+
</display>
50+
</class>
51+
<classid="6"language="java"name="com.iluwatar.reactor.framework.AbstractNioChannel"project="reactor"
52+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/AbstractNioChannel.java"binary="false"
53+
corner="BOTTOM_RIGHT">
54+
<positionheight="-1"width="-1"x="935"y="265"/>
55+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
56+
sort-features="false"accessors="true"visibility="true">
57+
<attributespublic="true"package="true"protected="true"private="false"static="true"/>
58+
<operationspublic="true"package="true"protected="true"private="false"static="true"/>
59+
</display>
60+
</class>
61+
<classid="7"language="java"name="com.iluwatar.reactor.framework.NioServerSocketChannel"project="reactor"
62+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java"binary="false"
63+
corner="BOTTOM_RIGHT">
64+
<positionheight="-1"width="-1"x="836"y="543"/>
65+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
66+
sort-features="false"accessors="true"visibility="true">
67+
<attributespublic="true"package="true"protected="true"private="false"static="true"/>
68+
<operationspublic="true"package="true"protected="true"private="true"static="true"/>
69+
</display>
70+
</class>
71+
<classid="8"language="java"name="com.iluwatar.reactor.framework.NioDatagramChannel"project="reactor"
72+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/NioDatagramChannel.java"binary="false"
73+
corner="BOTTOM_RIGHT">
74+
<positionheight="-1"width="-1"x="1110"y="539"/>
75+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
76+
sort-features="false"accessors="true"visibility="true">
77+
<attributespublic="true"package="true"protected="true"private="false"static="true"/>
78+
<operationspublic="true"package="true"protected="true"private="true"static="true"/>
79+
</display>
80+
</class>
81+
<classid="9"language="java"name="java.nio.channels.ServerSocketChannel"project="abstract-factory"
82+
file="/opt/Softwares/Eclipses/MARS/eclipse/jre/lib/rt.jar"binary="true"corner="BOTTOM_RIGHT">
83+
<positionheight="-1"width="-1"x="609"y="540"/>
84+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
85+
sort-features="false"accessors="true"visibility="true">
86+
<attributespublic="true"package="false"protected="true"private="false"static="true"/>
87+
<operationspublic="false"package="true"protected="false"private="true"static="true"/>
88+
</display>
89+
</class>
90+
<classid="10"language="java"name="java.nio.channels.DatagramChannel"project="abstract-factory"
91+
file="/opt/Softwares/Eclipses/MARS/eclipse/jre/lib/rt.jar"binary="true"corner="BOTTOM_RIGHT">
92+
<positionheight="-1"width="-1"x="1202"y="395"/>
93+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
94+
sort-features="false"accessors="true"visibility="true">
95+
<attributespublic="true"package="true"protected="true"private="true"static="true"/>
96+
<operationspublic="false"package="true"protected="false"private="true"static="true"/>
97+
</display>
98+
</class>
99+
<interfaceid="11"language="java"name="com.iluwatar.reactor.framework.ChannelHandler"project="reactor"
100+
file="/reactor/src/main/java/com/iluwatar/reactor/framework/ChannelHandler.java"binary="false"
101+
corner="BOTTOM_RIGHT">
102+
<positionheight="-1"width="-1"x="303"y="-1"/>
103+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
104+
sort-features="false"accessors="true"visibility="true">
105+
<attributespublic="true"package="true"protected="true"private="true"static="true"/>
106+
<operationspublic="true"package="true"protected="true"private="true"static="true"/>
107+
</display>
108+
</interface>
109+
<classid="12"language="java"name="com.iluwatar.reactor.app.LoggingHandler"project="reactor"
110+
file="/reactor/src/main/java/com/iluwatar/reactor/app/LoggingHandler.java"binary="false"corner="BOTTOM_RIGHT">
111+
<positionheight="-1"width="-1"x="297"y="147"/>
112+
<displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
113+
sort-features="false"accessors="true"visibility="true">
114+
<attributespublic="true"package="true"protected="true"private="false"static="true"/>
115+
<operationspublic="true"package="true"protected="true"private="false"static="true"/>
116+
</display>
117+
</class>
118+
<classid="13"language="java"name="com.iluwatar.reactor.app.App"project="reactor"
119+
file="/reactor/src/main/java/com/iluwatar/reactor/app/App.java"binary="false"corner="BOTTOM_RIGHT">
120+
<positionheight="133"width="148"x="123"y="266"/>
121+
<displayautosize="false"stereotype="true"package="true"initial-value="false"signature="true"
122+
sort-features="false"accessors="true"visibility="true">
123+
<attributespublic="true"package="true"protected="true"private="false"static="true"/>
124+
<operationspublic="true"package="true"protected="true"private="false"static="true"/>
125+
</display>
126+
</class>
127+
<realizationid="14">
128+
<endtype="SOURCE"refId="5"/>
129+
<endtype="TARGET"refId="3"/>
130+
</realization>
131+
<associationid="15">
132+
<endtype="SOURCE"refId="2"navigable="false">
133+
<attributeid="16"name="dispatcher"/>
134+
<multiplicityid="17"minimum="0"maximum="1"/>
135+
</end>
136+
<endtype="TARGET"refId="3"navigable="true"/>
137+
<displaylabels="true"multiplicity="true"/>
138+
</association>
139+
<realizationid="18">
140+
<bendpointx="309"y="348"/>
141+
<endtype="SOURCE"refId="4"/>
142+
<endtype="TARGET"refId="3"/>
143+
</realization>
144+
<associationid="19">
145+
<bendpointx="460"y="203"/>
146+
<endtype="SOURCE"refId="13"navigable="false">
147+
<attributeid="20"name="reactor"/>
148+
<multiplicityid="21"minimum="0"maximum="1"/>
149+
</end>
150+
<endtype="TARGET"refId="2"navigable="true"/>
151+
<displaylabels="true"multiplicity="true"/>
152+
</association>
153+
<dependencyid="22">
154+
<endtype="SOURCE"refId="8"/>
155+
<endtype="TARGET"refId="10"/>
156+
</dependency>
157+
<generalizationid="23">
158+
<endtype="SOURCE"refId="7"/>
159+
<endtype="TARGET"refId="6"/>
160+
</generalization>
161+
<associationid="24">
162+
<endtype="SOURCE"refId="6"navigable="false">
163+
<attributeid="25"name="handler"/>
164+
<multiplicityid="26"minimum="0"maximum="1"/>
165+
</end>
166+
<endtype="TARGET"refId="11"navigable="true"/>
167+
<displaylabels="true"multiplicity="true"/>
168+
</association>
169+
<associationid="27">
170+
<endtype="SOURCE"refId="6"navigable="false">
171+
<attributeid="28"name="reactor"/>
172+
<multiplicityid="29"minimum="0"maximum="1"/>
173+
</end>
174+
<endtype="TARGET"refId="2"navigable="true"/>
175+
<displaylabels="true"multiplicity="true"/>
176+
</association>
177+
<dependencyid="30">
178+
<endtype="SOURCE"refId="13"/>
179+
<endtype="TARGET"refId="12"/>
180+
</dependency>
181+
<associationid="31">
182+
<endtype="SOURCE"refId="2"navigable="false">
183+
<attributeid="32"name="selector"/>
184+
<multiplicityid="33"minimum="0"maximum="1"/>
185+
</end>
186+
<endtype="TARGET"refId="1"navigable="true"/>
187+
<displaylabels="true"multiplicity="true"/>
188+
</association>
189+
<realizationid="34">
190+
<endtype="SOURCE"refId="12"/>
191+
<endtype="TARGET"refId="11"/>
192+
</realization>
193+
<generalizationid="35">
194+
<endtype="SOURCE"refId="8"/>
195+
<endtype="TARGET"refId="6"/>
196+
</generalization>
197+
<dependencyid="36">
198+
<endtype="SOURCE"refId="7"/>
199+
<endtype="TARGET"refId="9"/>
200+
</dependency>
201+
<classifier-displayautosize="true"stereotype="true"package="true"initial-value="false"signature="true"
202+
sort-features="false"accessors="true"visibility="true">
203+
<attributespublic="true"package="true"protected="true"private="true"static="true"/>
204+
<operationspublic="true"package="true"protected="true"private="true"static="true"/>
205+
</classifier-display>
206+
<association-displaylabels="true"multiplicity="true"/>
207+
</class-diagram>

‎reactor/index.md

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
---
2+
layout:pattern
3+
title:Reactor
4+
folder:reactor
5+
permalink:/patterns/reactor/
6+
categories:Architectural
7+
tags:
8+
-Java
9+
-Difficulty-Expert
10+
---
11+
12+
**Intent:** The Reactor design pattern handles service requests that are delivered concurrently to an application by one or more clients. The application can register specific handlers for processing which are called by reactor on specific events. Dispatching of event handlers is performed by an initiation dispatcher, which manages the registered event handlers. Demultiplexing of service requests is performed by a synchronous event demultiplexer.
13+
14+
![Reactor](./etc/reactor.png"Reactor")
15+
16+
**Applicability:** Use Reactor pattern when
17+
18+
* a server application needs to handle concurrent service requests from multiple clients.
19+
* a server application needs to be available for receiving requests from new clients even when handling older client requests.
20+
* a server must maximize throughput, minimize latency and use CPU efficiently without blocking.
21+
22+
**Real world examples:**
23+
24+
*[Spring Reactor](http://projectreactor.io/)
25+
26+
**Credits**
27+
28+
*[Douglas C. Schmidt - Reactor](https://www.dre.vanderbilt.edu/~schmidt/PDF/Reactor.pdf)
29+
*[Doug Lea - Scalable IO in Java](http://gee.cs.oswego.edu/dl/cpjslides/nio.pdf)
30+
*[Netty](http://netty.io/)

‎reactor/pom.xml

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
<?xml version="1.0"?>
2+
<projectxsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
4+
<modelVersion>4.0.0</modelVersion>
5+
<parent>
6+
<groupId>com.iluwatar</groupId>
7+
<artifactId>java-design-patterns</artifactId>
8+
<version>1.6.0</version>
9+
</parent>
10+
<artifactId>reactor</artifactId>
11+
<dependencies>
12+
<dependency>
13+
<groupId>junit</groupId>
14+
<artifactId>junit</artifactId>
15+
<scope>test</scope>
16+
</dependency>
17+
</dependencies>
18+
</project>

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp