一滔悉、概述
LocalSocket可以在Android上實現(xiàn)跨進程的通信；區(qū)分服務端和客戶端缩多，服務端需要監(jiān)聽客戶端發(fā)送過來的消息腮恩。
二、服務端實現(xiàn)
xml文件
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical">
<TextView
android:id="@+id/tvMsg"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:minHeight="300dp"
android:text="收到消息"
android:textColor="#000000" />
<TextView
android:background="#888888"
android:id="@+id/tvToSend"
android:layout_width="match_parent"
android:layout_height="50dp"
android:gravity="center"
android:text="去發(fā)送信息"
android:textColor="#000000" />
</LinearLayout>
java代碼
public class LocalSocketServerActivity extends Activity {
private TextView tvMsg;
private LocalServerSocket mServerSocket = null;
private LocalSocket mSocket = null;
private InputStream mInputStream = null;
private static final String SOCKET_NAME = "demos.android.stormdzh.com.androiddemos.localsocket";
private static final String TAG = LocalSocketServerActivity.class.getSimpleName();
private final Handler mHandler = new Handler() {
public void handleMessage(android.os.Message msg) {
String dispMesg = (String) msg.obj;
tvMsg.setText(dispMesg);
}
};
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_local_socket_server);
tvMsg = findViewById(R.id.tvMsg);
createServerSocket();// 創(chuàng)建LocalServerSocket
//必須要在子線程里接收消息
new Thread(new Runnable() {
@RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR1)
@Override
public void run() {
acceptMsg();
}
}).start();
findViewById(R.id.tvToSend).setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
startActivity(new Intent(LocalSocketServerActivity.this,LocalSocketClientActivity.class));
}
});
}
@RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR1)
private void acceptMsg() {
try {
mSocket = mServerSocket.accept();//accept是個阻塞方法儒旬，這就是必須要在子線程接收消息的原因栏账。
} catch (IOException e1) {
e1.printStackTrace();
}
while (true) {
try {
byte[] buffer = new byte[1024];
mInputStream = mSocket.getInputStream();
int count = mInputStream.read(buffer);
String key = new String(Arrays.copyOfRange(buffer, 0, count));
Log.d(TAG, "ServerActivity mSocketOutStream==" + key);
if ("stop".equals(key)) {
closeSocketResource();
break;
}
Message msg = mHandler.obtainMessage();
msg.obj = key;
msg.sendToTarget();
} catch (IOException e) {
Log.d(TAG, "exception==" + e.fillInStackTrace().getMessage());
e.printStackTrace();
}
}
}
@RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR1)
private void closeSocketResource() {
closeSlient(mInputStream);
closeSlient(mSocket);
try {
if (mServerSocket != null) {
mServerSocket.close();
mServerSocket = null;
}
} catch (IOException ex) {
Log.e(TAG, "Failed closing ServerSocket" + ex.fillInStackTrace());
}
}
private void closeSlient(Closeable closeable) {
try {
if (closeable != null) {
closeable.close();
closeable = null;
}
} catch (IOException ex) {
Log.e(TAG, "Failed closing : " + closeable);
}
}
private void createServerSocket() {
if (mServerSocket == null) {
try {
/**注意這里new出LocalServerSocket的同時，系統(tǒng)層已經(jīng)同步做了bind和listen栈源。
* 我們看看new的過程：
* public LocalServerSocket(String name) throws IOException {
* impl = new LocalSocketImpl();
* impl.create(LocalSocket.SOCKET_STREAM);
* localAddress = new LocalSocketAddress(name);
* impl.bind(localAddress);
* impl.listen(LISTEN_BACKLOG);
* }
*/
mServerSocket = new LocalServerSocket(SOCKET_NAME);
} catch (IOException ex) {
}
}
}
}
三挡爵、客戶端實現(xiàn)
xml文件
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical">
<EditText
android:id="@+id/input_msg"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:layout_marginTop="10dp" />
<TextView
android:id="@+id/replay_btn"
android:layout_width="match_parent"
android:layout_height="50dp"
android:layout_marginTop="10dp"
android:background="#765432"
android:gravity="center"
android:text="回復"
android:textColor="#000000" />
<TextView
android:id="@+id/stop_btn"
android:layout_width="match_parent"
android:layout_height="50dp"
android:layout_marginTop="10dp"
android:background="#888888"
android:gravity="center"
android:text="關閉"
android:textColor="#000000" />
</LinearLayout>
java代碼
public class LocalSocketClientActivity extends Activity implements View.OnClickListener {
private EditText mEditText;
private LocalSocket mSocket;
private OutputStream mOut;
private static final String SOCKET_NAME = "demos.android.stormdzh.com.androiddemos.localsocket";
private static final String TAG = LocalSocketServerActivity.class.getSimpleName();
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_local_socket_client);
connect();
mEditText = (EditText) findViewById(R.id.input_msg);
findViewById(R.id.replay_btn).setOnClickListener(this);
findViewById(R.id.stop_btn).setOnClickListener(this);
}
private boolean connect() {
if (mSocket != null) {
return true;
}
try {
mSocket = new LocalSocket();//創(chuàng)建LocalSocket，模擬客戶端
LocalSocketAddress address = new LocalSocketAddress(SOCKET_NAME,
LocalSocketAddress.Namespace.ABSTRACT);
mSocket.connect(address);//連接TestLocalSocketServer
} catch (IOException ex) {
return false;
}
return true;
}
private boolean writeCommand(String cmdString) {
final byte[] cmd = cmdString.getBytes();
final int len = cmd.length;
try {
mOut = mSocket.getOutputStream();
mOut.write(cmd, 0, len);
Log.i(TAG, "ClientActivity write " + new String(cmd));
} catch (IOException ex) {
Log.e(TAG, "ClientActivity write error:" + ex.fillInStackTrace());
return false;
}
return true;
}
@Override
public void onClick(View v) {
switch (v.getId()) {
case R.id.replay_btn:
writeCommand(mEditText.getText().toString());
break;
case R.id.stop_btn:
writeCommand("stop");
break;
default:
break;
}
}
}
四甚垦、驗證
首先進入到服務端頁面茶鹃，之后點擊“去發(fā)送信息”按鈕到達客戶端頁面涣雕，在客戶端輸入文本，發(fā)送即可闭翩。如果希望測試跨進程可以把客戶端的Activity配置成一個單獨進程：
<activity android:name=".localsocket.LocalSocketClientActivity"
android:process="com.localsocket.process"
/>
