基于JavaEE、WebSocket的web聊天室

package com.ibcio;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;

import net.sf.json.JSONobject;

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

public class WebSocketMessageInbound extends MessageInbound {

	//当前连接的用户名称
	private final String user;

	public WebSocketMessageInbound（String user） {
		this.user = user;
	}

	public String getUser（） {
		return this.user;
	}

	//建立连接的触发的事件
	@Override
	protected void onOpen（WsOutbound outbound） {
		// 触发连接事件，在连接池中添加连接
		JSONobject result = new JSONobject（）;
		result.element（“type“ “user_join“）;
		result.element（“user“ this.user）;
		//向所有在线用户推送当前用户上线的消息
		WebSocketMessageInboundPool.sendMessage（result.toString（））;