Socket 功能在 Service 中实现
扫描二维码
随时随地手机看文章
前几天学习了 Android 下 Socket 编程。
学习 Socket 编程是有目的的,需要完成在手机与 PC 之间的通讯。通讯的内容是将手机上播放的 MP3 信息,通过 Socket 传输到 PC 端。
在参考网上相关 Socket 的文章后,基本上完成了 Socket 功能。所以就继续学习 Android 下音乐播放器的实现。在实现音乐播放器过程中,发现由于音乐播放器至少要有播放列表和正在播放两个 Activity,这样问题就来了:
(1). Socket 只是在第一个 Activity 中实现了,当这个 Activity 活动时没有问题。但此 Activity 非活动时,不能处理 Socket。
(2). 当反复进入第一个 Activity 时,会出现 Socket 初始化报错的问题。出现这样的错误,是由于 Sokcet 的初始化放在第一个 Activity 的 onCreate 中。
由于在做音乐播放器时使用了 Service,所以想到用 Serivce 来处理 Socket 应该没有问题。但是否有其它的方法呢?由于个人是刚刚接触 Android 编程,就不能确定这个问题了!
在论坛提问,得到的答案是:(1) Serivce; (2) 也可以更改activity的启动方式,让串口不重复创建。显然,第二种方法还没有接触过。采用第一种 Serivce 来实现更可靠一些。
首先,实现 Socket Service。
package com.jia.leozhengfirstapp; import java.io.IOException; import java.io.InputStream; import java.io.UnsupportedEncodingException; import java.net.ServerSocket; import java.net.Socket; import android.app.Service; import android.content.BroadcastReceiver; import android.content.Context; import android.content.Intent; import android.content.IntentFilter; import android.os.IBinder; import android.util.Log; public class SocketService extends Service { private Socket clientSocket = null; private ServerSocket mServerSocket = null; private SocketAcceptThread socketAcceptThread = null; private SocketReceiveThread socketReceiveThread = null; private SocketReceiver socketReceiver; public static final String SOCKER_ACTION = "com.jia.Socket.Control"; public static final String SOCKER_RCV = "com.jia.Socket.ReceiveStr"; private boolean stop = true; @Override public IBinder onBind(Intent intent) { // TODO Auto-generated method stub return null; } @Override public void onCreate() { super.onCreate(); Log.d("service", "socket service created"); socketReceiver = new SocketReceiver(); IntentFilter filter = new IntentFilter(); filter.addAction(SOCKER_ACTION); registerReceiver(socketReceiver, filter); socketAcceptThread = new SocketAcceptThread(); // 开启 Socket 监听线程 socketAcceptThread.start(); } @Override public void onStart(Intent intent, int startId) { Log.d("service", "socket service start"); } @Override public void onDestroy() { Log.d("service", "socket service destroy!"); } public class SocketReceiver extends BroadcastReceiver { @Override public void onReceive(Context context, Intent intent) { String action = intent.getAction(); if(action.equals(SOCKER_ACTION)) { String sub_action = intent.getExtras().getString("ACTION"); if(sub_action.equals("reconnect")) { Log.d("service", "socket service: reconnect."); socketAcceptThread = new SocketAcceptThread(); // 开启 Socket 监听线程 socketAcceptThread.start(); } } } } private class SocketAcceptThread extends Thread { @Override public void run() { Log.d("service", "socket service - SocketAcceptThread::run"); try { // 实例化ServerSocket对象并设置端口号为 12589 mServerSocket = new ServerSocket(12589); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { // 等待客户端的连接(阻塞) clientSocket = mServerSocket.accept(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } socketReceiveThread = new SocketReceiveThread(clientSocket); stop = false; // 开启接收线程 socketReceiveThread.start(); Intent sendIntent = new Intent(SOCKER_RCV); sendIntent.putExtra("action", "ClientIP"); sendIntent.putExtra("content", clientSocket.getInetAddress().getHostAddress()); // 发送广播,将被Activity组件中的BroadcastReceiver接收到 sendBroadcast(sendIntent); } } private class SocketReceiveThread extends Thread { private InputStream mInputStream = null; private byte[] buf; private String str = null; Socket sUsed; SocketReceiveThread(Socket s) { Log.d("service", "socket service - SocketReceiveThread"); try { // 获得输入流 this.mInputStream = s.getInputStream(); sUsed = s; } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } @Override public void run() { Log.d("service", "socket service - SocketReceiveThread::run"); while((!stop) && (!mServerSocket.isClosed())) { this.buf = new byte[2048]; // 读取输入的数据(阻塞读) try { this.mInputStream.read(buf); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } // 字符编码转换 try { this.str = new String(this.buf, "GB2312").trim(); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } Intent sendIntent = new Intent(SOCKER_RCV); sendIntent.putExtra("action", "RcvStr"); sendIntent.putExtra("content", this.str); // 发送广播,将被Activity组件中的BroadcastReceiver接收到 sendBroadcast(sendIntent); } } } }
在每个 Activity 中处理 SOCKER_RCV action,以响应 Socket 状态的变化和接收到数据。
Service 与 Activity 之间通讯需要使用到广播: Broadcast。
(1) 在 Activity 中定义全局的变量,如下:
public static final String SOCKER_ACTION = "com.jia.Socket.Control"; public static final String SOCKER_RCV = "com.jia.Socket.ReceiveStr"; SocketReceiver socketReceiver;
(2) 在 Activity 的 onCreate 中注册广播和启动 Socket Service,如下:
socketReceiver = new SocketReceiver(); IntentFilter socketIntentFilter = new IntentFilter(); socketIntentFilter.addAction(SOCKER_RCV); registerReceiver(socketReceiver,socketIntentFilter); Intent socketIntent = new Intent(); socketIntent.setClass(MainActivity.this, SocketService.class); startService(socketIntent); // 启动 Socket 服务
(3) SocketReceiver 是继承自 BroadcastReceiver 的类,实现如下:
public class SocketReceiver extends BroadcastReceiver { @Override public void onReceive(Context context, Intent intent) { // TODO Auto-generated method stub String action = intent.getAction(); if(action.equals(SOCKER_RCV)) { String url = intent.getExtras().getString("action"); if(url.equals("ClientIP")) { String strIP = intent.getExtras().getString("content"); } else if(url.equals("RcvStr")) { String strContent = intent.getExtras().getString("content"); } else if(url.equals("Disconnect")) { String strContent = intent.getExtras().getString("content"); } } } }
(4) Socket 功能实现后,测试时发现客户端(也就是 PC 端)断开时手机端未检测到 Socket 连接断开。
以前使用 WinCE 时,Socket(TCP) 断开时,无论是客户端、还是服务器都可以检测到 TCP 断开的事件,并处理。但 Android 下的 Socket 编程机制竟然没有这个东东。
一,测试时发现当 PC 端断开后,手机端的服务程序在执行到下面的代码段时不会阻塞,且函数的返回值是: -1。
二,在网上查找发现这个问题是 Android 下 Socket 都有的问题,可以通过发心跳包来处理。
所以将下面这段代码:
// 读取输入的数据(阻塞读) try { this.mInputStream.read(buf); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } 修改为如下的代码: try { int length = this.mInputStream.read(buf); if(-1 == length) { try { sUsed.sendUrgentData(0xff); } catch(Exception ex) { // 链接已断开 Log.v("service", "disconnect!!!"); stop = true; if(null != mServerSocket) { mServerSocket.close(); } Intent sendIntent = new Intent(SOCKER_RCV); sendIntent.putExtra("action", "Disconnect"); sendIntent.putExtra("content", "read is -1 & Urgent Exception!"); sendBroadcast(sendIntent); continue; } } } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); }