【移动应用开发技术】怎么在Android中使用Websocket实现一个聊天室

【移动应用开发技术】怎么在Android中使用Websocket实现一个聊天室

这期内容当中在下将会给大家带来有关怎么在Android中使用Websocket实现一个聊天室，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。WebSocket有以下几个特点

1.支持WebSocketRFC6455,DraftHybi-10+andWAMPv12.支持Android2.2以上3.非常好的兼容性4.高性能的异步设计5.非常容易使用的api6.与Androidapp非常好的结合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("munication.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("munication.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

=

n