概述
在同一局域网内,两台设备通过TCP进行通信聊天。
详细
一、准备工作
开发环境
jdk1.8
Eclipse Luna Service Release 1 (4.4.1)
运行环境:
华为荣耀6(Android4.4)、华为p9(Android7.0)
实现功能:同一局域网下,两台设备进行tcp通信聊天。
二、程序实现
工程截图:
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通信的使用基本就完成了,最后看一下图片,更容易理解其通信机制。
三、运行效果
运行:
选择作为客户端还是服务端
作为服务端如下:(服务端设置监听的端口号)
作为客户端如下:(客户端要设置连接的服务端的ip地址,及端口号)
四、其他补充
注:本文著作权归作者,由demo大师宣传,拒绝转载,转载需要作者授权