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

发布时间:2017-07-10
技术:Android4.4+jdk1.8

概述

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

详细

一、准备工作

开发环境

    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

2、实现思路

Android在包Java.NET包下提供了ServerSocketSocket类,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

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

Screenshot_2017-07-09-15-46-27.jpg

作为服务端如下:(服务端设置监听的端口号)

Screenshot_2017-07-09-15-47-42.jpg


作为客户端如下:(客户端要设置连接的服务端的ip地址,及端口号)

Screenshot_2017-07-09-15-50-54.jpg


四、其他补充

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


本实例支付的费用只是购买源码的费用,如有疑问欢迎在文末留言交流,如需作者在线代码指导、定制等,在作者开启付费服务后,可以点击“购买服务”进行实时联系,请知悉,谢谢