Java設計模式：觀察者

原文連結 譯者：秦建平

簡單來說，觀察者模式=釋出者+訂閱者。

下面是一個有關獵頭的典型的例子。在下面這張圖當中有兩個角色：獵頭和尋找工作的人。找工作的人向獵頭訂閱，告知自己希望得到一份工作，當有新的工作機會的時候，獵頭就會把這個資訊通知給曾經向他訂閱過的人。

java代碼

subject接口：

<code>1</code>

<code>public</code> <code>interface</code> <code>subject {</code>

<code>2</code>

<code>    </code><code>public</code> <code>void</code> <code>registerobserver(observer observer);</code>

<code>3</code>

<code>    </code><code>public</code> <code>void</code> <code>removeobserver(observer observer);</code>

<code>4</code>

<code>    </code><code>public</code> <code>void</code> <code>notifyallobservers();</code>

<code>5</code>

<code>}</code>

observer接口：

<code>public</code> <code>interface</code> <code>observer {</code>

<code>    </code><code>public</code> <code>void</code> <code>update(subject subject);</code>

headcounter實作了subject接口，實際上就是釋出者：

<code>01</code>

<code>public</code> <code>class</code> <code>headcounter</code><code>implements</code> <code>subject {</code>

<code>02</code>

<code>03</code>

<code>    </code><code>private</code> <code>list&lt;observer&gt; observerlist;</code>

<code>04</code>

<code>    </code><code>private</code> <code>list&lt;string&gt; joblist;</code>

<code>05</code>

<code>06</code>

<code>    </code><code>public</code> <code>headcounter(){</code>

<code>07</code>

<code>        </code><code>observerlist =</code><code>new</code> <code>arraylist&lt;observer&gt;();</code>

<code>08</code>

<code>        </code><code>joblist =</code><code>new</code> <code>arraylist&lt;string&gt;();</code>

<code>09</code>

<code>    </code><code>}</code>

<code>10</code>

<code>11</code>

<code>    </code><code>@override</code>

<code>12</code>

<code>    </code><code>public</code> <code>void</code> <code>registerobserver(</code><code>final</code> <code>observer observer) {</code>

<code>13</code>

<code>        </code><code>if</code><code>(! observerlist.contains(observer)){</code>

<code>14</code>

<code>            </code><code>observerlist.add(observer);</code>

<code>15</code>

<code>        </code><code>}</code>

<code>16</code>

<code>17</code>

<code>18</code>

<code>19</code>

<code>    </code><code>public</code> <code>void</code> <code>removeobserver(</code><code>final</code> <code>observer observer) {</code>

<code>20</code>

<code>        </code><code>if</code><code>(observerlist.contains(observer)){</code>

<code>21</code>

<code>            </code><code>observerlist.remove(observer);</code>

<code>22</code>

<code>23</code>

<code>24</code>

<code>25</code>

<code>26</code>

<code>    </code><code>public</code> <code>void</code> <code>notifyallobservers() {</code>

<code>27</code>

<code>        </code><code>for</code><code>(observer observer : observerlist){</code>

<code>28</code>

<code>            </code><code>observer.update(</code><code>this</code><code>);</code>

<code>29</code>

<code>30</code>

<code>31</code>

<code>32</code>

<code>    </code><code>public</code> <code>void</code> <code>addjob(</code><code>final</code> <code>string job){</code>

<code>33</code>

<code>        </code><code>this</code><code>.joblist.add(job);</code>

<code>34</code>

<code>        </code><code>notifyallobservers();</code>

<code>35</code>

<code>36</code>

<code>37</code>

<code>    </code><code>public</code> <code>list&lt;string&gt; getjobs(){</code>

<code>38</code>

<code>        </code><code>return</code> <code>joblist;</code>

<code>39</code>

<code>40</code>

<code>41</code>

<code>    </code><code>public</code> <code>string tostring(){</code>

<code>42</code>

<code>        </code><code>return</code> <code>joblist.tostring();</code>

<code>43</code>

jobseeker實作了observer接口，實際上就是訂閱者：

<code>public</code> <code>class</code> <code>jobseeker</code><code>implements</code> <code>observer {</code>

<code>    </code><code>private</code> <code>string name;</code>

<code>    </code><code>public</code> <code>jobseeker(string name){</code>

<code>        </code><code>this</code><code>.name = name;</code>

<code>    </code><code>public</code> <code>void</code> <code>update(subject subject) {</code>

<code>        </code><code>system.out.println(</code><code>this</code><code>.name +</code><code>" got notified!"</code><code>);</code>

<code>        </code><code>system.out.println(subject);</code>

程式執行個體入口：

<code>public</code> <code>class</code> <code>main {</code>

<code>    </code><code>public</code> <code>static</code> <code>void</code> <code>main(string[] args) {</code>

<code>        </code><code>headcounter headcounter =</code><code>new</code> <code>headcounter();</code>

<code>                </code><code>//注冊訂閱者</code>

<code>        </code><code>headcounter.registerobserver(</code><code>new</code> <code>jobseeker(</code><code>"mike"</code><code>));</code>

<code>        </code><code>headcounter.registerobserver(</code><code>new</code> <code>jobseeker(</code><code>"chris"</code><code>));</code>

<code>        </code><code>headcounter.registerobserver(</code><code>new</code> <code>jobseeker(</code><code>"jeff"</code><code>));</code>

<code>        </code><code>//通知所有訂閱者有新的工作機會</code>

<code>        </code><code>headcounter.addjob(</code><code>"google job"</code><code>);</code>

<code>        </code><code>headcounter.addjob(</code><code>"yahoo job"</code><code>);</code>