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（））;