android中使用WebSocket传递数据
2017-06-29 本文已影响1766人
NewHigh
第一步先下载ws的jar包
好像没有直接依赖的库，所以只能下jar包，放到libs中。
我使用的是github中的 这个地址 的库，
这是我下载好的jar包 --> 点这里
然后接着放到libs中进行依赖jar包
第二步创建Service
创建服务很简单，只需要在服务中创建对象，开启连接，发送信息，接受信息
因为我们接受的是json数据 ，所有对接受图片、文件等没有研究...（大家可以自己尝试）
public class SocketService extends Service {
public static String WEB_SOCKET_HOST = "ws://xxxx.xxx.com/wss";//这个是后台给的地址，根据自家的地址写上去即可
private static final String TAG = "ws";
private static WebSocketConnection webSocketConnection; // ws 对应的类
private static WebSocketOptions options = new WebSocketOptions(); //ws的个选项，声明出来即可使用了
private boolean isOpen;//ws打开的状态
@Nullable
@Override
public IBinder onBind(Intent intent) {
return new MyBinder();
}
@Override
public void onCreate() {
super.onCreate();
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
webSocketConnect();
return super.onStartCommand(intent, flags, startId);
}
@Override
public void onDestroy() {
super.onDestroy();
closeWebsocket();
}
//这里使用binder 主要是为了在activity中进行通讯， 大家也可以使用EventBus进行通讯
public class MyBinder extends Binder {
public SocketService getService(){
return SocketService.this;
}
}
/**
* 连接ws
*/
public void webSocketConnect() {
webSocketConnection = new WebSocketConnection();
try {
webSocketConnection.connect(WEB_SOCKET_HOST, new WebSocketHandler() {
//websocket启动时候的回调
@Override
public void onOpen() {
L.e("ws- onOpen: 开启成功！！");
isOpen = true ;
}
//websocket接收到消息后的回调
@Override
public void onTextMessage(String content) {
L.e(content + "接受到的ws信息" );
//这里可以使用EventBus将内容传递到activity
}
//websocket关闭时候的回调
@Override
public void onClose(int code, String reason) {
L.e("onClose: 服务器关闭！！" + reason);
isOpen = false ;
L.d("ws- 关闭");
}
}, options);
} catch (WebSocketException e) {
e.printStackTrace();
L.d("ws- 打开异常");
isOpen = false ;
closeWebsocket();
}
}
/**
* 关闭ws
*/
public void closeWebsocket() {
if (webSocketConnection != null && webSocketConnection.isConnected()) {
webSocketConnection.disconnect();
webSocketConnection = null;
}
}
/**
* ws是否连接
* @return
*/
public boolean isOpen(){
return isOpen ;
}
/**
* 发送信息，我们发送都是使用base64加密的，看自家需求
* @param base64
*/
public void sendMsg(String base64){
if (webSocketConnection != null && isOpen )webSocketConnection.sendTextMessage(base64);
L.d("ws- 发送 message");
}
}
第三步就是发送信息到后台
主要就是activity通过bindService，拿到service的对象，然后调用sendMsg（base64）即可，在onTextMessage（）回调中接受数据
//得到service的对象后，调用发送信息方法即可
private ServiceConnection mConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
WebSocketService.MyBinder binder = (WebSocketService.MyBinder) service;
mService = binder.getService();
mService.sendMsg(base64);//发送内容根据后台需求进行操作，我们是将json对象base64加密发送的
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
第四步（有发送就又接收）接收数据
接收数据，可以使用EventBus （这个方便）， 也可以自定义一个回调即可。
EventBus我就不多谢了，在接收的地方post出去，activity接收一下就行了。这里写下回调。
//在service中创建回调接口
private OnDataReceiverListener mListener ;
//设置监听
public void setOnDataReceiverListener(OnDataReceiverListener listener){
mListener = listener ;
}
public interface OnDataReceiverListener {
void onTextMsg(String text);
}
//在接收的地方，将回调接收即可
//websocket接收到消息后的回调
@Override
public void onTextMessage(String content) {
L.e(content + "接受到的ws信息" );
if (mListener != null){
mListener.onTextMsg(content);
}
}
//之后在activity中设置回调
@Override
protected void onResume() {
super.onResume();
if (mService != null){
mService.setOnDataReceiverListener(new WebSocketService.OnDataReceiverListener() {
@Override
public void onTextMsg(String text) {
L.d("接收到的信息 " + text);
}
});
}
}
现在初步的发送 、接收 都可以实现了，但是还有很多问题！！！比如 稳定性 ！！！（因为我们如果发送信息，不规律 或者长时间不发送，这个ws虽然开着，但是已经断开连接了0.0）
第五步 稳定性 优化
稳定性优化，我们做的也就是间断性的向后台的服务发送固定的无用信息，然后服务器在返回给自己。这样就爆出了一直连接（及所谓的 心跳 ）
//我们在ws open的时候就开始发送心跳
//websocket启动时候的回调
@Override
public void onOpen() {
L.e("ws- onOpen: 开启成功！！");
isOpen = true ;
mTimer = new Timer();
mTimer.schedule(new TimerTask() {
@Override
public void run() {
//发送信息有时候会异常，不过不多...
try {
webSocketConnection.sendTextMessage("固定数据， 自己接受");
}catch (Exception e){
e.printStackTrace();
}
}
} , 0 , 60 * 1000);
}
现在稳定性算是差不多告一段落了，（给自己一个棒棒糖！）。
前段时间我们经理给我们说这个也会有问题的！！！（一个大棒槌过来了）
最后一小步（经理说的一句话：事件驱动）
事件驱动：什么意思？google去....
经理说的大概意思是：ws是在服务里的，我们操作数据是在activity中的，所以你在操作的时候，也不一定确认ws是否开启了？所以需要在activity中进行操作....（不懂），但是大家看代码就应该能懂的了0.0
//在这之前我们已经做了基础了， 就是那个心跳！我们发送什么 服务器就返回什么，使用timer来操作
if (mService != null){
mService.setOnDataReceiverListener(new WebSocketService.OnDataReceiverListener() {
@Override
public void onTextMsg(String text) {
L.d("接收到的信息 " + text);
//这里保存一下当前接受到数据后的时间
mWsXinTiao = System.currentTimeMillis();
}
});
}
mTimer = new Timer();
mTimer.schedule(new TimerTask() {
@Override
public void run() {
if (System.currentTimeMillis() - mWsXinTiao > 60 * 1000) {
//进到自己就说明ws的心跳在规定的时间内 未 接收信息，看自己的需求了
//比如stopService ， 在startService
//或者将有关ws获取的数据的一系列操作给Gone掉，屏蔽掉，提个示 whatever...
//这样就保证了 activity这边的关于ws的一系列操作都是可行的！有反应的！！！及 以activity为主导进行操作！
}
}
} , 0 , 75 * 1000);//比心跳时间多一点 也没事。
