Android进程间通信之socket通信

2022-11-20 10:11:58

用Java中的socket编程。

通过socket实现两个应用之间的通信，可以接收和发送数据，同时将接收到的数据显示在activity界面上。

Server端：

ServerLastly.java

package com.example.driverexam;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.InetAddress;

import java.net.ServerSocket;

import java.net.Socket;

import android.os.Handler;

import android.os.Message;

import android.util.Log;

/**

 * 通过Socket实现

 * @author Administrator

 *

 */

public class ServerLastly implements Runnable{

    private static final String TAG="ServerLastly";

    ServerSocket server;

    Socket client;

    PrintWriter os;

    BufferedReader is;

    Handler handler;

    /**

     * 此处不将连接代码写在构造方法中的原因：

     * 我在activity的onCreate()中创建示例，如果将连接代码 写在构造方法中，服务端会一直等待客户端连接，界面没有去描绘，会一直出现白屏。

     * 直到客户端连接上了，界面才会描绘出来。原因是构造方法阻塞了主线程，要另开一个线程。在这里我将它写在了run()中。

     */

    ServerLastly(Handler handler){

        this.handler=handler;

//        Log.i(TAG, "Server=======打开服务=========");

//        try {

//            server=new ServerSocket(8888);

//            client=server.accept();

//            Log.i(TAG, "Server=======客户端连接成功=========");

//             InetAddress inetAddress=client.getInetAddress();

//             String ip=inetAddress.getHostAddress();

//            Log.i(TAG, "===客户端ID为:"+ip);

//            os=new PrintWriter(client.getOutputStream());

//            is=new BufferedReader(new InputStreamReader(client.getInputStream()));

//

//        } catch (IOException e) {

//            // TODO Auto-generated catch block

//            e.printStackTrace();

//        }

    }

    //发数据

    public void send(String data){

        if (os!=null) {

            os.println(data);

            os.flush();

        }

    }

    //接数据

    @Override

    public void run() {

        Log.i(TAG, "Server=======打开服务=========");

        try {

            server=new ServerSocket(8080);

            client=server.accept();

            Log.i(TAG, "Server=======客户端连接成功=========");

             InetAddress inetAddress=client.getInetAddress();

             String ip=inetAddress.getHostAddress();

            Log.i(TAG, "===客户端ID为:"+ip);

            os=new PrintWriter(client.getOutputStream());

            is=new BufferedReader(new InputStreamReader(client.getInputStream()));

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

        String result="";

        while(true){

            try {

                result=is.readLine();

                Log.i(TAG, "服务端接到的数据为："+result);

                //把数据带回activity显示

                Message msg=handler.obtainMessage();

                msg.obj=result;

                msg.arg1=0x11;

                handler.sendMessage(msg);

            } catch (IOException e) {

                // TODO Auto-generated catch block

                e.printStackTrace();

            }

        }

    }

    public void close(){

        try {

            if (os!=null) {

                os.close();

            }

            if (is!=null) {

                is.close();

            }

            if(client!=null){

                client.close();

            }

            if (server!=null) {

                server.close();

            }

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

}

ServerFinallyActivity.java

package com.example.driverexam;

import android.app.Activity;

import android.os.Bundle;

import android.os.Handler;

import android.os.Message;

import android.view.View;

import android.widget.EditText;

import android.widget.TextView;

public class ServerFinallyActivity extends Activity {

    EditText et_serverSend;

    TextView tv_showReceiveData;

//    ServerFinally server;

    ServerLastly server;

    StringBuffer receiveData=new StringBuffer();

    Handler handler=new Handler(new Handler.Callback() {

        @Override

        public boolean handleMessage(Message msg) {

            if (msg.arg1==0x11) {

                receiveData.append((String)msg.obj);

                tv_showReceiveData.setText(receiveData);

                receiveData.append("\r\n");

            }

            return false;

        }

    });

    @Override

    protected void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.activity_server_finally);

        et_serverSend=(EditText) findViewById(R.id.et_serverSend);

        tv_showReceiveData=(TextView) findViewById(R.id.tv_showReceiveData);

//        server=new ServerFinally();

//        new Thread(server).start();

        server=new ServerLastly(handler);

        new Thread(server).start();

    }

    //发数据

    public void btn_serverSend(View view){

        server.send(et_serverSend.getText().toString()+"");

        et_serverSend.setText("");

    }

    @Override

    protected void onDestroy() {

        super.onDestroy();

        server.close();

    }

}

Client端：

ClientLastly.java

package com.fqhx.remoteserviceclient;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

import android.os.Handler;

import android.os.Message;

import android.util.Log;

/**

 * 通过socket实现

 * @author Administrator

 *

 */

public class ClientLastly implements Runnable{

    private static final String TAG="ClientLastly";

    private static final String NAME="com.repackaging.localsocket";

    private int timeout=30000;

    Socket client;

    PrintWriter os;

    BufferedReader is;

    Handler handler;

    ClientLastly(Handler handler){

        this.handler=handler;

//        try {

//            //连接服务器

//            client=new Socket("localhost", 8888);

//            Log.i(TAG, "Client=======连接服务器成功=========");

//            client.setSoTimeout(timeout);

//            os=new PrintWriter(client.getOutputStream());

//            is=new BufferedReader(new InputStreamReader(client.getInputStream()));

//        } catch (IOException e) {

//            // TODO Auto-generated catch block

//            e.printStackTrace();

//        }

    }

    //发数据

    public void send(String data){

        Log.i(TAG, "Client=======data=========");

        if (os!=null) {

            os.println(data);

            os.flush();

        }

    }

    //接收据

    @Override

    public void run() {

        try {

            //连接服务器

//            client=new Socket("192.168.191.1", 8080);

            client=new Socket("localhost", 8080);

            Log.i(TAG, "Client=======连接服务器成功=========");

            client.setSoTimeout(timeout);

            os=new PrintWriter(client.getOutputStream());

            is=new BufferedReader(new InputStreamReader(client.getInputStream()));

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

        String result="";

        while(true){

            try {

                result=is.readLine();

                Log.i(TAG, "客户端接到的数据为："+result);

                //将数据带回acitvity显示

                Message msg=handler.obtainMessage();

                msg.arg1=0x12;

                msg.obj=result;

                handler.sendMessage(msg);

            } catch (IOException e) {

                // TODO Auto-generated catch block

                e.printStackTrace();

            }

        }

    }

    public void close(){

        try {

            if (os!=null) {

                os.close();

            }

            if (is!=null) {

                is.close();

            }

            if(client!=null){

            client.close();

            }

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

}

ClientFinallyActivity.java

package com.fqhx.remoteserviceclient;

import android.app.Activity;

import android.os.Bundle;

import android.os.Handler;

import android.os.Message;

import android.view.View;

import android.widget.EditText;

import android.widget.TextView;

public class ClientFinallyActivity extends Activity {

//    ClientFinally client;

    EditText et_clientSend;

    TextView tv_showReceiveDataClient;

    ClientLastly client;

    StringBuffer receiveData=new StringBuffer();

    Handler handler=new Handler(new Handler.Callback() {

        @Override

        public boolean handleMessage(Message msg) {

            if (msg.arg1==0x12) {

                receiveData.append((String)msg.obj);

                tv_showReceiveDataClient.setText(receiveData);

                receiveData.append("\r\n");

            }

            return false;

        }

    });

    @Override

    protected void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.activity_client_finally);

        et_clientSend=(EditText) findViewById(R.id.et_clientSend);

        tv_showReceiveDataClient=(TextView) findViewById(R.id.tv_showReceiveDataClient);

//        client=new ClientFinally();

//        new Thread(client).start();

        client=new ClientLastly(handler);

        new Thread(client).start();

    }

    public void btn_clientSend(View view){

        client.send(et_clientSend.getText().toString()+"");

        et_clientSend.setText("");

    }

    @Override

    protected void onDestroy() {

        super.onDestroy();

        client.close();

    }

}
上一篇：Android进程间的通信之AIDL


下一篇：Microsoft .Net Remoting系列专题之三：Remoting事件处理全接触