Android基于TCP的局域网聊天通信

悠悠 2022-05-31 08:43 265阅读 0赞

# 概述 #

在同一局域网内，两台设备通过TCP进行通信聊天。

# 详细 #

#### 代码下载：[http://www.demodashi.com/demo/10567.html][http_www.demodashi.com_demo_10567.html] ####

#### 一、准备工作 ####

开发环境

jdk1.8

Eclipse Luna Service Release 1 (4.4.1)

运行环境：

华为荣耀6（Android4.4）、华为p9（Android7.0）

实现功能：同一局域网下，两台设备进行tcp通信聊天。

详情请参考博客：http://blog.csdn.net/VNanyesheshou/article/details/74896575

#### 二、程序实现 ####

工程截图：

![QQ图片20170709222819.png][QQ_20170709222819.png]

2、实现思路

[Android][]在包[Java][][.NET][]包下提供了ServerSocket和Socket类，ServerSocket用于创建服务器的Socket。Socket用于实例化客户端的Socket。当连接成功，客户端和服务端都会产生一个Socket实例，通过此Socket进行通信。

3、具体代码

服务端

服务端ServerSocket的构造方法有以下几种：

ServerSocket ()：构造一个新的未绑定的ServerSocket。

ServerSocket (int port)：构造一个新的ServerSocket并绑定到指定端口，如果port等于0，则端口由系统自动分配。

ServerSocket (int port, int backlog)：构造一个新的ServerSocket并绑定到指定端口，并指定进入队列的数目。如果port等于0，则端口由系统自动分配。

ServerSocket (int port, int backlog, InetAddress localAddress)：构造一个新的ServerSocket并绑定到指定端口和指定的地址，并指定进入队列的数目。如果port等于0，则端口由系统自动分配。如果localAddress为null，则可以使用任意地址。

1 开启服务

try {    //开启服务、指定端口号
        ServerSocket mServerSocket = new ServerSocket(5566);
    } catch (IOException e) {
        e.printStackTrace();
        Toast.makeText(this, "服务开启失败", Toast.LENGTH_SHORT).show();    return;
    }

2调用ServerSocket的accept(),监听连接请求，如果客户端请求连接，则接收连接，返回Scoekt对象。

Socket mSocket = mServerSocket.accept();

3 调用Socket类的getInputStream()和getOutputStream()获取输入输出流。

//获取输入流
    mInStream = mSocket.getInputStream();
    //获取输出流
    mOutStream = mSocket.getOutputStream();

步骤4：开始发送、接收数据。

try {   //发送
        mOutStream.write(msg.getBytes());
        mOutStream.flush();
    }catch (Exception e) {
        e.printStackTrace();
    }
        
    byte[] buffer = new byte[1024];
    //循环执行read，用来接收数据。
    //数据存在buffer中，count为读取到的数据长度。
    int count = mInStream.read(buffer);

步骤5：服务不再需要，则关闭服务

if(mServerSocket != null){
        try {
            mServerSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

客户端

TCP客户端工作具体步骤：

步骤1：创建一个Socket，连接到服务器端、指定端口号。放在子线程中运行，否则会有问题。

class SocketConnectThread extends Thread{
        public void run(){        try {            //指定ip地址和端口号
                mSocket = new Socket(mIpAddress,mClientPort);            if(mSocket != null){                //获取输出流、输入流
                    mOutStream = mSocket.getOutputStream();
                    mInStream = mSocket.getInputStream();
                }
            } catch (Exception e) {
                e.printStackTrace();
                mHandler.sendEmptyMessage(MSG_SOCKET_CONNECTFAIL);            return;
            }
            Log.i(TAG,"connect success");
            mHandler.sendEmptyMessage(MSG_SOCKET_CONNECT);
        }
    
    }

步骤2：调用Socket类的getInputStream()和getOutputStream()获取输入输出流。

具体代码如上所示。

步骤3：发送、接收数据。（发送接收数据与服务端方法相同。）

发送数据：

private void writeMsg(String msg){    if(msg.length() == 0 || mOutStream == null)        return;    try {   //发送
            mOutStream.write(msg.getBytes());
            mOutStream.flush();
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

接收数据：(从输入流读取数据，需要在一个子线程中循环运行下面的方法。)

byte[] buffer = new byte[1024];//循环执行read，用来接收数据。//数据存在buffer中，count为读取到的数据长度。int count = mInStream.read(buffer);

步骤4：关闭Socket

public void closeConnection(){
        try {
            if (mOutStream != null) {
                mOutStream.close(); //关闭输出流
                mOutStream = null;
            }
            if (mInStream != null) {
                mInStream.close(); //关闭输入流
                mInStream = null;
               }
            if(mSocket != null){
                mSocket.close();  //关闭socket
                mSocket = null;
            }
           } catch (IOException e) {
               e.printStackTrace();
           }
        if(mReceiveThread != null){
            mReceiveThread.threadExit();
            mReceiveThread = null;
        }
    }

在清单文件中添加权限

AndroidManifest.xml 文件

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

TCP通信的使用基本就完成了，最后看一下图片，更容易理解其通信机制。

![image.png][]

#### 三、运行效果 ####

运行：

![image.png][image.png 1]

选择作为客户端还是服务端

![Screenshot\_2017-07-09-15-46-27.jpg][Screenshot_2017-07-09-15-46-27.jpg]

作为服务端如下：（服务端设置监听的端口号）

![Screenshot\_2017-07-09-15-47-42.jpg][Screenshot_2017-07-09-15-47-42.jpg]

作为客户端如下：（客户端要设置连接的服务端的ip地址，及端口号）

![Screenshot\_2017-07-09-15-50-54.jpg][Screenshot_2017-07-09-15-50-54.jpg]

#### 四、其他补充 ####

参考文章：http://blog.csdn.net/VNanyesheshou/article/details/74896575

#### 注：本文著作权归作者，由demo大师（[http://www.demodashi.com][http_www.demodashi.com]）宣传，拒绝转载，转载需要作者授权 ####

[http_www.demodashi.com_demo_10567.html]: http://www.demodashi.com/demo/10567.html
[QQ_20170709222819.png]: /images/20220531/bd7c3f2d144a43be97ecbb252c9bf352.png
[Android]: http://lib.csdn.net/base/android
[Java]: http://lib.csdn.net/base/java
[.NET]: http://lib.csdn.net/base/dotnet
[image.png]: /images/20220531/08cae7f106dd4f079d613e2c025affd3.png
[image.png 1]: /images/20220531/67cbb8cee72c4319aec6a5e66a54de30.png
[Screenshot_2017-07-09-15-46-27.jpg]: /images/20220531/8c89a4ebb63645aab0af231c172f222c.png
[Screenshot_2017-07-09-15-47-42.jpg]: /images/20220531/6d0840fe108f4c809451f7a67870723f.png
[Screenshot_2017-07-09-15-50-54.jpg]: /images/20220531/e03df282c3c642a1a639169d66db9eb2.png
[http_www.demodashi.com]: http://www.demodashi.com/