HTML 5とTomcat WebSocketServiceに基づくチャットルームのシンプルな実装

	
  HTML5    
	

		

			

			

							</div>
		</div>
		<br/>
		<input type="button" value="  "/> <input type="button" value="  " disabled="disabled" id="send_btn" title="Ctrl+Enter  "/>
	</div>

<script type="text/javascript">
	var socket;
	var receive_text = document.getElementById("up");
	var send_text = document.getElementById("send");
	function addText(msg) {
		receive_text.innerHTML += "<br/>" + msg;
		receive_text.scrollTop = receive_text.scrollHeight;
	}
	var chat = function(obj) {
		obj.disabled = "disabled";
		try{
			socket = new WebSocket('<%=WsBasePath + "chat"%>');
			receive_text.innerHTML += "<font color=green>       ……</font>";
		}catch(e){
			receive_text.innerHTML += "<font color=red>  ，        html5，   IE10         、      ！</font>";
		}
		//  Socket 
		socket.onopen = function(event) {
			falg=false;
			addText("<font color=green>    ！</font>");
			document.getElementById("send_btn").disabled = false;
			send_text.focus();
			document.onkeydown = function(event) {
				if (event.keyCode == 13 && event.ctrlKey) {
					send();
				}
			};
		};
		socket.onmessage = function(event) {
			addText(event.data);
		};

		socket.onclose = function(event) {
			addText("<font color=red>    ！</font>");
			obj.disabled = "";
		};
	};
	var send = function(obj) {
		if (send_text.value == "") {
			return;
		}
		socket.send(send_text.value);
		send_text.value = "";
		send_text.focus();
	};
</script>
</code></pre> 
  <br/> 
  <br/> ChatWebSocketServlet.java 
   
   
  <pre><code>package com.baiyang.lc.websocketservlet;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;

import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServletRequest;

import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.StreamInbound;
import org.apache.catalina.websocket.WebSocketServlet;
import org.apache.catalina.websocket.WsOutbound;

@WebServlet("/chat")
public class ChatWebSocketServlet extends WebSocketServlet {
	private final Map<integer wsoutbound=""> map = new HashMap<integer wsoutbound="">();

	/**
	 * 
	 */
	private static final long serialVersionUID = -1058445282919079067L;

	@Override
	protected StreamInbound createWebSocketInbound(String arg0, HttpServletRequest request) {
		return new ChatMessageInbound();
	}

	class ChatMessageInbound extends MessageInbound {

		@Override
		protected void onOpen(WsOutbound outbound) {
			map.put(outbound.hashCode(), outbound);
			super.onOpen(outbound);
		}

		@Override
		protected void onClose(int status) {
			map.remove(getWsOutbound().hashCode());
			super.onClose(status);
		}

		@Override
		protected void onBinaryMessage(ByteBuffer buffer) throws IOException {
			// TODO Auto-generated method stub

		}

		@Override
		protected void onTextMessage(CharBuffer buffer) throws IOException {
			String msg = buffer.toString();
			Date date = new Date();
			SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
			msg = " <font color="green">      " + sdf.format(date) + "</font><br/> " + msg;
			broadcast(msg);
		}

		private void broadcast(String msg) {
			Set<integer> set = map.keySet();
			for (Integer integer : set) {
				WsOutbound outbound = map.get(integer);
				CharBuffer buffer = CharBuffer.wrap(msg);
				try {
					outbound.writeTextMessage(buffer);
					outbound.flush();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}
}
</integer></integer></integer></code></pre> 
  <br/> 
  <br/> 
        
  <br/> 
  <br/> 
  <br/> 
   
 </div> 
</div>
                            </div>
                        </div>