回答編集履歴
4
\)が足りないのを修正
test
CHANGED
@@ -50,7 +50,7 @@
|
|
50
50
|
|
51
51
|
paramServletContextEvent.getServletContext().setAttribute("tmpMap",
|
52
52
|
|
53
|
-
new ConcurrentHashMap<String, Integer>();
|
53
|
+
new ConcurrentHashMap<String, Integer>());
|
54
54
|
|
55
55
|
}
|
56
56
|
|
3
コーディング例で new new ってなってたのを修正
test
CHANGED
@@ -50,7 +50,7 @@
|
|
50
50
|
|
51
51
|
paramServletContextEvent.getServletContext().setAttribute("tmpMap",
|
52
52
|
|
53
|
-
new
|
53
|
+
new ConcurrentHashMap<String, Integer>();
|
54
54
|
|
55
55
|
}
|
56
56
|
|
2
コーディング例の追加
test
CHANGED
@@ -11,3 +11,165 @@
|
|
11
11
|
|
12
12
|
|
13
13
|
また、複数のユーザがまったく同時に編集しようとすると、今、編集中のユーザがいないことを確認する if 文とユーザ情報を設定する setAttribute 呼び出しを同時に実行してしまう可能性があるため、 synchronized なメソッドで実装して排他制御する必要があると思います。
|
14
|
+
|
15
|
+
|
16
|
+
|
17
|
+
---
|
18
|
+
|
19
|
+
以下に排他制御について書いてみますが、手元に servlet をデバッグする環境がないので、すべて未検証(コンパイルエラーがでるかもしれない)であることをご了承ください。
|
20
|
+
|
21
|
+
|
22
|
+
|
23
|
+
いろいろ、ググッて調べたのですが、「もし、未登録であれば登録する」というロジックで満足に排他制御できているサンプルが見つかりませんでした。ServletContext は複数のスレッド(ユーザからのリクエスト)から同時にアクセスされるので、「もし、未登録であれば」という if 文を2つのスレッドが同時に実行すると、両方のスレッドが「登録する」処理を実行してしまうので、バグってしまいます。また、この手のバグはなかなか顕在化しないので、たちが悪いです。
|
24
|
+
|
25
|
+
|
26
|
+
|
27
|
+
まず、ServletContext にマップを登録する処理ですが、初期化イベントのリスナーで実行しておくべきです。アプリケーションが動作する前に実行されるので、排他制御の必要がありません。
|
28
|
+
|
29
|
+
|
30
|
+
|
31
|
+
```java
|
32
|
+
|
33
|
+
import javax.servlet.ServletContextEvent;
|
34
|
+
|
35
|
+
import javax.servlet.ServletContextListener;
|
36
|
+
|
37
|
+
import java.util.concurrent.ConcurrentHashMap;
|
38
|
+
|
39
|
+
@javax.servlet.annotation.WebListener
|
40
|
+
|
41
|
+
public class WebListener implements ServletContextListener {
|
42
|
+
|
43
|
+
@Override
|
44
|
+
|
45
|
+
public void contextDestroyed(ServletContextEvent paramServletContextEvent) {}
|
46
|
+
|
47
|
+
@Override
|
48
|
+
|
49
|
+
public void contextInitialized(ServletContextEvent paramServletContextEvent) {
|
50
|
+
|
51
|
+
paramServletContextEvent.getServletContext().setAttribute("tmpMap",
|
52
|
+
|
53
|
+
new new ConcurrentHashMap<String, Integer>();
|
54
|
+
|
55
|
+
}
|
56
|
+
|
57
|
+
}
|
58
|
+
|
59
|
+
```
|
60
|
+
|
61
|
+
|
62
|
+
|
63
|
+
こうしておいて、サーブレット側では ConcurrentHashMap の putIfAbsent を使って排他制御します。
|
64
|
+
|
65
|
+
|
66
|
+
|
67
|
+
```java
|
68
|
+
|
69
|
+
package wiki;
|
70
|
+
|
71
|
+
|
72
|
+
|
73
|
+
import java.io.IOException;
|
74
|
+
|
75
|
+
import java.util.concurrent.ConcurrentHashMap;
|
76
|
+
|
77
|
+
|
78
|
+
|
79
|
+
import javax.servlet.ServletContext;
|
80
|
+
|
81
|
+
import javax.servlet.ServletException;
|
82
|
+
|
83
|
+
import javax.servlet.http.HttpServlet;
|
84
|
+
|
85
|
+
import javax.servlet.http.HttpServletRequest;
|
86
|
+
|
87
|
+
import javax.servlet.http.HttpServletResponse;
|
88
|
+
|
89
|
+
import javax.servlet.http.HttpSession;
|
90
|
+
|
91
|
+
|
92
|
+
|
93
|
+
import Account.AccountBean;
|
94
|
+
|
95
|
+
|
96
|
+
|
97
|
+
public class UpdateUserCheck extends HttpServlet {
|
98
|
+
|
99
|
+
|
100
|
+
|
101
|
+
@Override
|
102
|
+
|
103
|
+
public synchronized void doGet(HttpServletRequest request, HttpServletResponse response)
|
104
|
+
|
105
|
+
throws ServletException, IOException {
|
106
|
+
|
107
|
+
|
108
|
+
|
109
|
+
HttpSession session = request.getSession(false);
|
110
|
+
|
111
|
+
ServletContext sc = getServletContext(); // アプリケーションスコープの取得
|
112
|
+
|
113
|
+
|
114
|
+
|
115
|
+
String name = request.getParameter("name"); // 編集中のページ名を取得
|
116
|
+
|
117
|
+
AccountBean account = (AccountBean) session.getAttribute("account");
|
118
|
+
|
119
|
+
|
120
|
+
|
121
|
+
/* 初期化イベントリスナーで登録したMapを取得する */
|
122
|
+
|
123
|
+
ConcurrentHashMap<String, Integer> map = autoCast(sc.getAttribute("tmpMap")); // メソッドでキャスト
|
124
|
+
|
125
|
+
|
126
|
+
|
127
|
+
String message = null;
|
128
|
+
|
129
|
+
final Integer currentUid = autoCast(map.putIfAbsent(name, account.getId()));
|
130
|
+
|
131
|
+
if (currentUid != null) {
|
132
|
+
|
133
|
+
if (! currentUid.equals(account.getId())) {
|
134
|
+
|
135
|
+
message = "他のユーザーにて編集中です";
|
136
|
+
|
137
|
+
request.setAttribute("message", message);
|
138
|
+
|
139
|
+
request.getRequestDispatcher("list").forward(request, response);
|
140
|
+
|
141
|
+
} else {
|
142
|
+
|
143
|
+
request.getRequestDispatcher("/wikiView/update.jsp").forward(request, response);
|
144
|
+
|
145
|
+
}
|
146
|
+
|
147
|
+
} else {
|
148
|
+
|
149
|
+
request.getRequestDispatcher("/wikiView/update.jsp").forward(request, response);
|
150
|
+
|
151
|
+
}
|
152
|
+
|
153
|
+
}
|
154
|
+
|
155
|
+
|
156
|
+
|
157
|
+
/* 戻り値の型に合わせてキャスト */
|
158
|
+
|
159
|
+
@SuppressWarnings("unchecked")
|
160
|
+
|
161
|
+
public static <T> T autoCast(Object obj) {
|
162
|
+
|
163
|
+
T castedObject = (T) obj;
|
164
|
+
|
165
|
+
return castedObject;
|
166
|
+
|
167
|
+
}
|
168
|
+
|
169
|
+
}
|
170
|
+
|
171
|
+
```
|
172
|
+
|
173
|
+
|
174
|
+
|
175
|
+
また、ユーザが編集を終了するときに map から削除するようにしておかないと、上記コードは動作しません。さらに編集状態のまま、ログアウト時や放置されてセッションがタイムアウトした時も編集状態を開放する処理が必要であると思われます。
|
1
排他制御の必要性を追記
test
CHANGED
@@ -7,3 +7,7 @@
|
|
7
7
|
|
8
8
|
|
9
9
|
ただし、掲示板が複数ある場合は、掲示板毎に管理する必要があるので、ハッシュテーブルなどを使う必要があると思います。
|
10
|
+
|
11
|
+
|
12
|
+
|
13
|
+
また、複数のユーザがまったく同時に編集しようとすると、今、編集中のユーザがいないことを確認する if 文とユーザ情報を設定する setAttribute 呼び出しを同時に実行してしまう可能性があるため、 synchronized なメソッドで実装して排他制御する必要があると思います。
|