怎么在Android中使用Websocket实现一个聊天室
这期内容当中小编将会给大家带来有关怎么在Android中使用Websocket实现一个聊天室,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
10年积累的做网站、成都网站建设经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站制作后付款的网站建设流程,更有坡头免费网站建设让你可以放心的选择与我们合作。
WebSocket有以下几个特点
1.支持 WebSocket RFC6455, Draft Hybi-10+ and WAMP v1
2.支持Android 2.2以上
3.非常好的兼容性
4.高性能的异步设计
5.非常容易使用的api
6.与Android app非常好的结合
7.没有网络操作在UI线程
8.开源
下面是官网给的一段示例代码
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()); } }
是不是挺简单的,在onOpen()方法中做与服务器连接的操作,onTextMessage()是收到服务器发送给客服端的消息,onClose()是与服务器断开走的方法,发送消息用sendTextMessage()。
我是在MsgService 实现与服务器的连接与发送消息的,直接上代码:
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) { //连接失败也把效应的提示信息告诉用户 Mapmap = 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(); } }
下面是Fragment的代码
public class ChatRoomFragment extends Fragment { private View view, rootView, headView; private MsgService msgService; private UListView chatlist;//因为ScrollVie与ListView有冲突,重写了ListView private static Listmlist; 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 (); 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(); } }
上述就是小编为大家分享的怎么在Android中使用Websocket实现一个聊天室了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注创新互联行业资讯频道。
当前题目:怎么在Android中使用Websocket实现一个聊天室
文章URL:http://scyanting.com/article/jssehe.html