private void pullWebSocket(){
	// TODO 使用WebSocket实时推送
	SharedPreferences sharedPref = this.getSharedPreferences("appdata",Context.MODE_PRIVATE);
	List<BasicNameValuePair> headers = new ArrayList<BasicNameValuePair>();
	headers.add(new BasicNameValuePair("Cookie","JSESSIONID="+sharedPref.getString("SessionId", "")));
	/*SharedPreferences sharedPref1 = this.getSharedPreferences("userdata",Context.MODE_PRIVATE);
	headers.add(new BasicNameValuePair("uid",sharedPref1.getInt("uid", -1)+""));*/
	try {
		wsc.connect("ws"+declare.getHost_url().substring(4)+"pull.ws", null, new WebSocketConnectionHandler(){

			@Override
			public void onClose(int code, String reason) {
				Log.i(TAG, "onClose reason="+reason);
			}

			@Override
			public void onOpen() {
				Log.i(TAG, "后台推送已连接");
			}

			//接收文本消息
			@Override
			public void onTextMessage(String payload) {
				readingParse(payload);
			}
		}, new WebSocketOptions(), headers);
	} catch (WebSocketException e) {
		e.printStackTrace();
	}
}
 

public void connect() {
     try {
         WebSocketOptions options = new WebSocketOptions();

         options.setMaxFramePayloadSize(256000);
application.getConnection().connect(sessionData.getHost(), handler, options);
         eventManager.fire(ConnectionEventListener.ConnectionEventType.CONNECTED);
     } catch (WebSocketException e) {
         e.printStackTrace();
         Ln.e("Exception while connecting");
     }
 }