(サポート切れててゴメン。たぶん1.8でも動くよ（祈り）。）
なんか画面の表示下のコード表示が微妙にバグ踏んでるけど、まあいいや。
(勝手に<Session>を</session>で閉じなくていいんだよ......</session>消せないし...)
※102行目の</session></session>は無視おねがいします。
package websocketchatter;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Collections;
import java.util.Date;
import java.util.HashSet;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
/**
* WebSocketのURIを指定。
* @author USER
*/
@ServerEndpoint("/MessageReceiptor")
public class MessageReceiptor {
private static Set peers = Collections.synchronizedSet(new HashSet());
private static File file;
private static BufferedWriter writer;
/* いずれかのセッションからメッセージが送信された場合のメソッド */
@OnMessage
public String onMessage(String message) {
for(Session s : peers) {
/*
非同期に各セッションにメッセージを送る。
*/
s.getAsyncRemote().sendText(message);
try {
System.out.println(message);
writer.write(message, 0, message.length());
writer.newLine();
writer.flush();
} catch (IOException ex) {
Logger.getLogger(MessageReceiptor.class.getName()).log(Level.SEVERE, null, ex);
}
System.out.println(message);
}
return null;
}
/* セッションがクローズされた際に呼び出されるメソッド */
@OnClose
public void onClose(Session peer) {
peers.remove(peer);
}
/* セッションがオープンされた際に呼び出されるメソッド */
@OnOpen
public void onOpen(Session peer) {
/*
この処理は非常に雑なので参考にしないで。
永続化に際してはJPAとかを使ってRDBに書き込んだりしたほうがいいと思います。
滅茶苦茶雑な処理です。(こんな書き方はしてはいけません。)
修正したら正式版を別記事で挙げます。
*/
if(file == null) {
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("YYYYMMdd");
String str = format.format(date);
file = new File(str+".log");
try {
System.out.println("File Path:" + file.getCanonicalPath());
} catch (IOException ex) {
Logger.getLogger(MessageReceiptor.class.getName()).log(Level.SEVERE, null, ex);
}
}
if(writer == null) {
try {
writer = new BufferedWriter(new FileWriter(file));
} catch (IOException ex) {
Logger.getLogger(MessageReceiptor.class.getName()).log(Level.SEVERE, null, ex);
}
}
try {
BufferedReader reader = new BufferedReader(new FileReader(file));
for(String str = reader.readLine(); str != null; str = reader.readLine()) {
peer.getAsyncRemote().sendText(str);
}
} catch (FileNotFoundException ex) {
Logger.getLogger(MessageReceiptor.class.getName()).log(Level.SEVERE, null, ex);
} catch (IOException ex) {
Logger.getLogger(MessageReceiptor.class.getName()).log(Level.SEVERE, null, ex);
}
peers.add(peer);
}
}
そのうち、クライアント側処理(jQuery + Bootstrapを組み合わせた場合かな～...)
と組み合わせた時の画像か動画でも載せます。
ちな、jQueryとBootstrapの使い方として正しいのかは保証しません。
なので、今後のToDoとしては以下の通り
- クライアント側(ブラウザ側実装の提示)
- PowerPointスライド(画像)によるサーバサイド処理の内容の表示
- @OnOpen処理の屑さ加減の改善(JPAを使ったRDBによる永続化
