Android使用Websocket实现聊天室
作者:luyouxin 发布时间:2023-07-07 13:01:59
标签:Android,Websocket,聊天室
最近的项目中要实现一个聊天的功能,类似于斗鱼TV的聊天室功能,与服务器端人商量后决定用WebSocket来做,但是在这之前我只知道Socket但是听都没有听过WebSocket,但是查看了相关的材料以后发现实现一个聊天室其实是很简单的!下面我们先来看看WebSocket。
Autobahn|Android 是由Autobahn开发一个开源的Java/Android网络库,实现了WebSocket协议和Web应用程序消息传输协议来创建本地移动的WebSocket/ WAMP的客服端。
WebSocket允许在网络上双向的发送实时消息,WAMP 为客服端增加了一个协议异步远程调用、推送、订阅。
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) {
//连接失败也把效应的提示信息告诉用户
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();
}
}
下面是Fragment的代码
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();
}
}
这样一个简单的聊天室功能就实现了直接上图。
来源:https://blog.csdn.net/luyouxin/article/details/51030317
0
投稿
猜你喜欢
- 声明:下面的实例全部在linux下尝试,window下未尝试。有兴趣者可以试一下。文章针c初学者。c语言的强符号和弱符号是c初学者经常容易犯
- 背景:在Android中按照数据保存的方式,可以分为如下几种Content Provider (用的SQLite实现),SQLite,Sha
- 前言上一篇我们认识了Kotlin编程语言,也搭建好开发环境。本篇就进入Kotlin的基础语法介绍,与其他编程语言一样,Kotlin也有自己的
- 各位亲们可以尝试以下代码:注:这里我就只有一个html标签对来说明问题了,首部之类的东西,自己添加。<html> &n
- 最近没事写了一个简易浏览器,在刚开始写的时候遇到一些问题,主要的问题就是如何在自己的webview中显示所有的网页数据,不过不指
- 本文实例为大家分享了java实现 * 系统的具体代码,供大家参考,具体内容如下//车类public abstract class Vehi
- 最近项目中需要实现定时执行任务,比如定时计算会员的积分、调用第三方接口等,由于项目采用spring框架,所以这里结合spring框架来介绍。
- 1. 前言现在很多应用都有小悬浮窗的功能,比如看直播的时候,通过Home键返回桌面,直播的小窗口仍可以在屏幕上显示。下面将介绍下悬浮窗的的一
- 本文实例为大家分享了OpenCV实现人脸识别程序的具体代码,供大家参考,具体内容如下//Haar特征检测,人脸识别算法,是用xml作为训练后
- Android 中ScrollView嵌套GridView,ListView的实例在Android开发中,经常有一些UI需要进行固定styl
- 这里使用的是dynamic-datasource-spring-boot-starter ,它是一个基于springboot的快速集成多数据
- 前言我们在学习Windows应用程序开发中,经常会用到消息对话框给用户或者管理员一些的消息提示,它们都是基于对MessageBox类的消息对
- 【程序1】题目:有1、2、3、4个数字,能组成多少个互不相同且无重复数字的三位数?都是多少?1.程序分析:可填在百位、十位、个位的数字都是1
- 这篇文章主要介绍了Java如何实现自定义异常类,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参
- 你知道String、StringBuilder、Stringbuffer的区别吗?当你创建字符串的时候,有考虑过该使用哪个吗?别急,这篇文章
- 本文实例讲述了C++实现的链表类。分享给大家供大家参考。具体如下:#include <iostream>using namesp
- 本文实例讲述了Java实现接口的枚举类。分享给大家供大家参考,具体如下:一 点睛枚举类也可以实现一个或多个接口。与普通类实现一个或多个接口完
- Visual Studio 2022 默认.net framework4.8,而4.6~4.7版本的.net framework可以通过方法
- SharedPreferences介绍:SharedPreferences是Android平台上一个轻量级的存储类,主要是保存一些常用的配置
- 最近在做上传文件的服务,简单看了网上的教程。结合实践共享出代码。由于网上的大多数没有服务端的代码,这可不行呀,没服务端怎么调试呢。Ok,先上