try {
LocalServerSocket server = new LocalServerSocket(SOCKET_ADDRESS);
while (true) {
//Log.i(TAG, "begin accept");
LocalSocket receiver = server.accept();
if (receiver != null) {
InputStream input = receiver.getInputStream();

byte[] bytes = new byte[4];
int size = input.read(bytes, 0, 4);
if(size!=4) Log.i(TAG, "received command len:" + String.valueOf(size));

int cmd_len = ((bytes[0] & 0xFF) << 24)|((bytes[1] & 0xFF) << 16)
|((bytes[2] & 0xFF) << 8)|(bytes[3] & 0xFF);

Log.i(TAG, "received cmd_len:"+String.valueOf(cmd_len));
if(cmd_len>0){
byte[] ArrayOfByte = new byte[cmd_len];
size = input.read(ArrayOfByte, 0, cmd_len);
Log.i(TAG, "received data len:" + String.valueOf(size));
Parcel parcel = Parcel.obtain();
parcel.unmarshall(ArrayOfByte, 0, ArrayOfByte.length);
parcel.setDataPosition(0);
processRequest(receiver,parcel);
}

}
}
} catch (IOException e) {
Log.e(getClass().getName(), e.getMessage());
}
private void sendResult(LocalSocket paramLocalSocket, Parcel paramParcel) throws IOException{
byte[] arrayOfByte1 = new byte[4];
byte[] arrayOfByte2 = paramParcel.marshall();
Log.i(TAG, "enter sendResult!");
arrayOfByte1[0] = 0;
arrayOfByte1[1] = 0;
arrayOfByte1[2] = (byte)(arrayOfByte2.length >> 8 & 0xFF);
arrayOfByte1[3] = (byte)(arrayOfByte2.length & 0xFF);

paramLocalSocket.getOutputStream().write(arrayOfByte1);
paramLocalSocket.getOutputStream().write(arrayOfByte2);
}

private void processRequest(LocalSocket paramLocalSocket, Parcel paramParcel)
{
int cmd = paramParcel.readInt();
//Log.i(TAG,"parcel:"+String.valueOf(cmd));
if(cmd>0&&cmd //String info = "unknown";
Parcel parcel_info = Parcel.obtain();
TelephonyManager tm = (TelephonyManager) getSystemService(TELEPHONY_SERVICE);
switch (cmd)
{
case CMMB_REQUEST_GET_IMSI:{
Log.i(TAG, "received CMMB_REQUEST_GET_IMSI command!");
/*
* 唯一的用户ID：
* 例如：IMSI(国际移动用户识别码) for a GSM phone.
* 需要权限：READ_PHONE_STATE
*/
String info = tm.getSubscriberId();//String
if(info!=null) Log.i(TAG, info);
parcel_info.writeInt(CMMB_REQUEST_GET_IMSI);
parcel_info.writeString(info);
}
break;
....
try {
sendResult(paramLocalSocket, parcel_info);
} catch (IOException e) {
// TODO Auto-generated catch block
Log.e(getClass().getName(), e.getMessage());
e.printStackTrace();
}

}