怎么在Android中使用Websocket实现一个聊天室

private final WebSocketConnection mConnection = new WebSocketConnection();

private void start() {

 final String wsuri = "ws://localhost:9000";

 try {
 mConnection.connect(wsuri, new WebSocketHandler() {

  @Override
  public void onOpen() {
  Log.d(TAG, "Status: Connected to " + wsuri);
  mConnection.sendTextMessage("Hello, world!");
  }

  @Override
  public void onTextMessage(String payload) {
  Log.d(TAG, "Got echo: " + payload);
  }

  @Override
  public void onClose(int code, String reason) {
  Log.d(TAG, "Connection lost.");
  }
 });
 } catch (WebSocketException e) {

 Log.d(TAG, e.toString());
 }
}

public class MsgService extends Service {
 private final IBinder binder = new MsgBinder();
 private boolean flag = false;
 private WebSocketConnection mConnection;
 private Intent intent = new Intent("com.example.communication.RECEIVER");

 public void startSocket(String sn) {

 final String wsuri = "ws://localhost:9000";
 final JSONObject json = new JSONObject();
 try {
  json.put("type", "command");
  json.put("command", "auth");
  json.put("key", Constants.API_KEY);
  json.put("access_token", UserManager.getInstance().getUser()
   .getUserAccessToken());
  json.put("user_token", UserManager.getInstance().getUser()
   .getLYUserToken());
  json.put("sn", sn);
 } catch (Exception e) {
  e.printStackTrace();
 }

 try {
  mConnection.connect(wsuri, new WebSocketHandler() {

  @Override
  public void onOpen() {
   if (!flag) {
   //与服务器连接认证
   mConnection.sendTextMessage(json.toString());
   } else {
   }
  }

  @Override
  public void onTextMessage(String payload) {
   intent.putExtra("message", payload);
   sendBroadcast(intent);//发送广播给Fragment
  }
  @Override
  public void onClose(int code, String reason) {
   //连接失败也把效应的提示信息告诉用户
   Map<String, String> map = new HashMap<>();
   map.put("status", "failed");
   map.put("type", "command");
   map.put("command", "auth");
   String msg = map.toString();
   intent.putExtra("message", msg);
   sendBroadcast(intent);

  }
  });
 } catch (WebSocketException e) {
  e.printStackTrace();
 }
 }

 //发送消息的方法
 public void sendMessage(String message) {
 mConnection.sendTextMessage(message);
 }


 @Override
 public IBinder onBind(Intent intent) {
 return binder;
 }

 @Override
 public void onCreate() {
 mConnection = new WebSocketConnection();
 super.onCreate();
 }

 @Override
 public int onStartCommand(Intent intent, int flags, int startId) {
 return super.onStartCommand(intent, flags, startId);
 }

 public class MsgBinder extends Binder {
 /**
  * 获取当前Service的实例
  *
  * @return
  */
 public MsgService getService() {
  return MsgService.this;
 }
 }

 @Override
 public void onDestroy() {
 super.onDestroy();
 mConnection.disconnect();
 }

}

public class ChatRoomFragment extends Fragment {
 private View view, rootView, headView;
 private MsgService msgService;
 private UListView chatlist;//因为ScrollVie与ListView有冲突，重写了ListView
 private static List<ChatMessage> mlist;
 private ChatMessage chatMessage;
 private ChatMessageAdapter chatMessageAdapter;
 private ScrollView scrollView;
 private Handler handler = new Handler() {
 public void handleMessage(Message msg) {
  switch (msg.what) {
  case 1:
   msgService
    .startSocket(((PlayActivity) getActivity()).getSn());
   break;
  default:
   break;
  }

 }
 };
 //通过聊天室来更新在线人数
 public interface UpdataOnlineUsersListener {
 public void updataOnlineUser(int number);
 }

 private UpdataOnlineUsersListener mCallback;
 private EditText messageEditText;
 private Button sendBtn;
 private Intent mIntent;
 private MsgReceiver msgReceiver;
 private ServiceConnection conn = new ServiceConnection() {
 @Override
 public void onServiceDisconnected(ComponentName name) {
  Log.d("time", "msg");
 }

 @Override
 public void onServiceConnected(ComponentName name, IBinder service) {
  // 返回一个MsgService对象
  MsgService.MsgBinder binder = (MsgService.MsgBinder) service;
  if (binder != null) {
  Log.d("time", "msg");
  }
  msgService = binder.getService();
  if (msgService != null) {
  Log.d("time", "msg");
  Message msg = new Message();
  msg.what = 1;
  handler.sendMessage(msg);
  }
 }
 };

 public View onCreateView(LayoutInflater inflater, ViewGroup container,
    Bundle savedInstanceState) {
 view = inflater.inflate(R.layout.fragment_chat_room, container, false);
 return view;
 }

 public void bindChatService() {
 getActivity().bindService(mIntent, conn, Context.BIND_AUTO_CREATE);
 }

 public void destoryChatService() {
 getActivity().unbindService(conn);
 }

 @Override
 public void onAttach(Activity activity) {
 super.onAttach(activity);
 mCallback = (UpdataOnlineUsersListener) (activity);
 }

 @Override
 public void onActivityCreated(Bundle savedInstanceState) {
 super.onActivityCreated(savedInstanceState);
 // 动态注册广播接收器
 msgReceiver = new MsgReceiver();
 IntentFilter intentFilter = new IntentFilter();
 intentFilter.addAction("com.example.communication.RECEIVER");
 getActivity().registerReceiver(msgReceiver, intentFilter);
 mIntent = new Intent(getActivity(), MsgService.class);
 bindChatService();
 chatlist = (UListView) view.findViewById(R.id.chatlist);
 messageEditText = (EditText) view.findViewById(R.id.input);
 scrollView = (ScrollView) view.findViewById(R.id.scroll);
 scrollView.setFocusable(false);
 mlist = new ArrayList<ChatMessage>();
 chatMessageAdapter = new ChatMessageAdapter(mlist, getActivity());
 chatlist.setAdapter(chatMessageAdapter);
 chatlist.setVerticalScrollBarEnabled(true);
 sendBtn = (Button) view.findViewById(R.id.send);
 builder = new AlertDialog.Builder(getActivity());
 sendBtn.setOnClickListener(new OnClickListener() {

  @Override
  public void onClick(View v) {
  final View view = v;
  if (UserManager.getInstance().getUser().getGuest()) {
   ToastUtil.getInstance().showToast(getActivity(), getResources().getString(R.string.is_not_login));
  } else {
   String message = messageEditText.getText().toString();
   if (!message.equals("")) {
   JSONObject json = new JSONObject();
   try {
    json.put("type", "message");
    json.put("to", "");
    json.put("message", message);
   } catch (Exception e) {
   }

   msgService.sendMessage(json.toString());
   } else {
   Toast.makeText(getActivity(),
    getResources().getString(R.string.textisnull),
    Toast.LENGTH_SHORT).show();
   }

  }
  HideKeyboard(v);
  messageEditText.setText("");
  }

 });
 rootView = (View) view.findViewById(R.id.rootview);
 rootView.setFocusable(true);
 rootView.setFocusableInTouchMode(true);
 rootView.requestFocus();
 setRetainInstance(true);

 }
 //隐藏软键盘
 private void HideKeyboard(View v) {
 InputMethodManager imm = (InputMethodManager) v.getContext()
  .getSystemService(Context.INPUT_METHOD_SERVICE);
 if (imm.isActive()) {
  imm.hideSoftInputFromWindow(v.getApplicationWindowToken(), 0);
 }
 }

 @Override
 public void onResume() {
 super.onResume();
 scrollView.smoothScrollTo(0, 0);
 }
 //接受服务端发送的消息
 public class MsgReceiver extends BroadcastReceiver {

 @Override
 public void onReceive(Context context, Intent intent) {
  String msg = intent.getStringExtra("message");
  try {
  JSONObject json = new JSONObject(msg);
  if (json.getString("type").equals("command")) {
   String command = json.getString("command");
   if (command.equals("auth")) {
   {
    chatMessage = new ChatMessage("tips", "服务器连接中...",
     "111", "111");
    mlist.add(chatMessage);
    chatMessageAdapter.notifyDataSetChanged();
   }
   if (json.getString("status").equals("success")) {
    chatMessage = new ChatMessage("tips", "服务器连接中成功",
     "111", "111");
   } else {
    chatMessage = new ChatMessage("tips", "服务器连接中失败",
     "111", "111");
   }
   mlist.add(chatMessage);
   chatMessageAdapter.notifyDataSetChanged();
   } else if (command.equals("online_status")) {
   int onlineUser = json.getInt("online");
   mCallback.updataOnlineUser(onlineUser);
   }

  } else if (json.getString("type").equals("message")) {
   chatMessage = new ChatMessage(json.getString("type"),
    json.getString("from"), json.getString("content"),
    json.getString("time"));
   mlist.add(chatMessage);
   chatMessageAdapter.notifyDataSetChanged();
  }

  Log.d("time", mlist.toString());
  } catch (JSONException e) {
  e.printStackTrace();
  }

  chatlist.setSelection(chatMessageAdapter.getCount());//让ListView滑到最下面
  }
 }

 @Override
 public void onDestroy() {
 // 停止服务
 getActivity().unbindService(conn);
 // 注销广播
 getActivity().unregisterReceiver(msgReceiver);
 super.onDestroy();
 }
}