android进程间通信ipc Socket (二)

逃离我推掉我的手 2022-06-06 03:27 251阅读 0赞

**通过Socket通信有两种方式：**

> 流式套接字（TCP）  
> 用户数据报套接字（UDP）

**下面介绍 流式套接字（TCP）方式通信**

![这里写图片描述][SouthEast]

> 显示的log是服务器端打印的日志 接收客户端的消息

**服务端代码**

package com.example.socketdemo;
    
    import android.app.Service;
    import android.content.Intent;
    import android.os.IBinder;
    import android.util.Log;
    
    import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.net.SocketException;
    
    /** * Created by yw on 2017/10/28. */
    
    public class TPCSocket extends Service { 
        private boolean mIsServiceDestoryed = false;
        @Override
        public void onCreate() {
            //监听连接的状态
            new TcpThread().start();
            super.onCreate();
        }
    
        @Override
        public IBinder onBind(Intent intent) {
            return null;
        }
    
        @Override
        public void onDestroy() {
            mIsServiceDestoryed = true;
            super.onDestroy();
        }
    
        private class TcpThread extends Thread { 
            @Override
            public void run() {
                ServerSocket serverSocket = null;
                try {
                    serverSocket = new ServerSocket(8888);
                } catch (IOException e) {
                    e.printStackTrace();
                    return;
                }
    
                //接受客户端的请求
                try {
                    final Socket socket = serverSocket.accept();
    
                    //回应客户端
                    new Thread() {
                        @Override
                        public void run() {
                            try {
                                handleMsg(socket);
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    }.start();
                } catch (Exception e) {
                    e.printStackTrace();
                }
    
            }
        }
    
        private void handleMsg(Socket socket) throws Exception{
    
                //发送消息
            PrintWriter out = new PrintWriter(
                        new BufferedWriter(new
                                OutputStreamWriter(socket.getOutputStream())), true);
    
    // BufferedWriter o = new BufferedWriter(new
    // OutputStreamWriter(socket.getOutputStream()));
    // o.write("jfdk");
    
            //OutputStreamWriter(socket.getOutputStream())) 字符流通向字节流
    
                //接受消息
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //InputStreamReader(socket.getInputStream()) 字节流通向字符流
    
            out.println("来聊天啊");
    
            //在服务没有销毁的时候 一直循环处理消息
            while (!mIsServiceDestoryed) {
               try {
                   String msg = in.readLine();
    
                   if (msg == null) {
                       //客户端断开了
                       break;
                   }
                   Log.d("yw", msg);
                   //给客户端回消息
                   out.println("服务器发来的消息");
               } catch (SocketException e) {
                   Log.d("yw", e.getMessage());
                   break;
               }
            }
    
            //关闭资源
            out.close();
            in.close();
            socket.close();
        }
    }

**总要逻辑**

> 服务启动的时候，开个线程  
> ServerSocket serverSocket = new ServerSocket(8888);  
> Socket socket = serverSocket.accept();  
> 监听8888端口，等待客户端的连接；

**注册服务**  
[其他的进程名命名方法][Link 1]

**客户端代码**

package com.example.socketdemo;
    
    import android.app.ProgressDialog;
    import android.content.Intent;
    import android.os.Handler;
    import android.os.Message;
    import android.os.SystemClock;
    import android.support.v7.app.AppCompatActivity;
    import android.os.Bundle;
    import android.util.Log;
    import android.view.View;
    import android.widget.EditText;
    import android.widget.TextView;
    import android.widget.Toast;
    
    import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.Socket;
    
    public class MainActivity extends AppCompatActivity { 
        private TextView mMsgList;
        private EditText mEt;
        private boolean mIsConn = false;
        private Socket mSocket = null;
        private PrintWriter mPrintWriter;
        private ProgressDialog mDialog;
        private Thread mThread;
        @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.activity_main);
    
            mMsgList = (TextView) findViewById(R.id.tv_msg_list);
            mEt = (EditText) findViewById(R.id.et);
    
            Intent intent = new Intent(this, TPCSocket.class);
            startService(intent);
        }
    
        private class MyThread extends Thread { 
            @Override
            public void run() {
                while (mSocket == null) {
                    try {
                        mSocket = new Socket("127.0.0.1", 8888);
                        mIsConn = true;
    
                        //发送的对象
                        mPrintWriter = new PrintWriter(new BufferedWriter(new OutputStreamWriter(mSocket.getOutputStream())), true);
                    } catch (IOException e) {
                        mIsConn = false;
                        e.printStackTrace();
                        SystemClock.sleep(1000); //重试时间间隔1秒
                    }
                }
                //发送连接成功消息
                mHandler.sendEmptyMessage(1);
    
                //接受消息
                while (mIsConn && !mSocket.isClosed()) {
                    try {
                        BufferedReader reader = new BufferedReader(new InputStreamReader(mSocket.getInputStream()));
                        String msg = reader.readLine();
                        Log.d("yw", msg);
                        Message message = new Message();
                        Bundle bundle = new Bundle();
                        bundle.putString("msg", msg);
                        message.setData(bundle);
                        message.what = 2;
                        mHandler.sendMessage(message);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    
        public void connService(View view) {
            if (mIsConn) {
                Toast.makeText(this, "不要重复连接哦", Toast.LENGTH_SHORT).show();
                return;
            }
            //连接服务
            mDialog =
                    new ProgressDialog(this);
            mDialog.setCancelable(false);
            mDialog.show();
    
            mThread = new MyThread();
            mThread.start();
        }
    
        public void disService(View view) {
            if (!mIsConn) {
                Toast.makeText(this, "不要重复断开哦", Toast.LENGTH_SHORT).show();
                return;
            }
            //断开服务
            try {
                mThread.interrupt();
                mSocket.close();
                mSocket = null;
                mIsConn = false;
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        public void sendMsg(View view) {
            if (!mIsConn) {
                Toast.makeText(this, "连接服务后才能发送哦", Toast.LENGTH_SHORT).show();
                return;
            }
            //发送消息
            new Thread() {
                @Override
                public void run() {
                    mPrintWriter.println(mEt.getText().toString());
                }
            }.start();
        }
    
        private Handler mHandler = new Handler(){
            @Override
            public void handleMessage(Message msg) {
                switch (msg.what) {
                    case 1:
                        //连接成功
                        mDialog.dismiss();
                        Toast.makeText(MainActivity.this, "连接成功", Toast.LENGTH_SHORT).show();
                        break;
                    case 2:
                        //显示消息
                        String message = msg.getData().getString("msg");
                        mMsgList.setText(mMsgList.getText() + "\n" + message);
                        break;
                }
                super.handleMessage(msg);
            }
        };
    }

**总要逻辑**

> 开个线程连接服务器，连接成功之后，通过Handler通知ui主线程，然后ui线程会提示用户连接成功。连接成功，socket不为空，同时会一直监听服务器发来的消息，一旦有消息，通过Handler通知ui主线程更新界面。

**view界面代码**

<?xml version="1.0" encoding="utf-8"?>
    <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:orientation="vertical" android:layout_height="match_parent" tools:context="com.example.socketdemo.MainActivity">
        <Button android:text="连接" android:onClick="connService" android:layout_width="wrap_content" android:layout_height="wrap_content" />
        <Button android:text="断开" android:onClick="disService" android:layout_width="wrap_content" android:layout_height="wrap_content" />
        <Button android:onClick="sendMsg" android:text="发消息" android:layout_width="wrap_content" android:layout_height="wrap_content" />
        <EditText android:id="@+id/et" android:layout_marginBottom="10dp" android:layout_width="match_parent" android:layout_height="wrap_content" />
    
        <TextView android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="消息列表：\n" />
    
        <TextView android:id="@+id/tv_msg_list" android:layout_width="wrap_content" android:layout_height="wrap_content" />
    </LinearLayout>

**最后加上权限**

<uses-permission android:name="android.permission.INTERNET" />

不然会报异常：

java.net.SocketException: Permission denied

[> 源码下载地址][Link 2]

[SouthEast]: /images/20220606/24996c39d88e4aed8f784a749ca2d9e7.png
[Link 1]: http://blog.csdn.net/yang_yang1994/article/details/78379961
[Link 2]: https://github.com/yang-mr/Study_Notes/tree/master/IpcDemo/socketdemo