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();
}
}