質問編集履歴
1
追記
test
CHANGED
File without changes
|
test
CHANGED
@@ -163,3 +163,51 @@
|
|
163
163
|
何度も同じ質問をしてしまい申し訳ありませんが
|
164
164
|
|
165
165
|
よろしくお願いいたします。
|
166
|
+
|
167
|
+
|
168
|
+
|
169
|
+
---
|
170
|
+
|
171
|
+
追記
|
172
|
+
|
173
|
+
|
174
|
+
|
175
|
+
メッセージのサーバー側の処理を記載いたします。
|
176
|
+
|
177
|
+
```java
|
178
|
+
|
179
|
+
@OnMessage
|
180
|
+
|
181
|
+
public void onMessage(String message , Session sessionID) throws IOException, ServletException {
|
182
|
+
|
183
|
+
// クライアントからの受信時
|
184
|
+
|
185
|
+
for (Session session : sessions) {
|
186
|
+
|
187
|
+
session.getBasicRemote().sendText("{\"command\":\"message\", \"text\": \"" + message.replace("\\", "\\\\").replace("\"", "\\\"") + "\" , \"sessionid\": \"" + sessionid + "\"}");
|
188
|
+
|
189
|
+
MessageDao messagedao = new MessageDao();
|
190
|
+
|
191
|
+
try{
|
192
|
+
|
193
|
+
messagedao.connect();
|
194
|
+
|
195
|
+
int userid = messagedao.selectSessionID(sessionid).getUserid();
|
196
|
+
|
197
|
+
int roomid = messagedao.selectSessionID(sessionid).getRoomid();
|
198
|
+
|
199
|
+
messagedao.insertMessage(userid, roomid, message);
|
200
|
+
|
201
|
+
messagedao.close();
|
202
|
+
|
203
|
+
}catch(Exception e){
|
204
|
+
|
205
|
+
e.printStackTrace();
|
206
|
+
|
207
|
+
}
|
208
|
+
|
209
|
+
}
|
210
|
+
|
211
|
+
}
|
212
|
+
|
213
|
+
```
|