Socket 通信原理(Android客户端和服务器以TCP&&UDP方式互通)

本文涉及的产品
数据传输服务 DTS,数据同步 small 3个月
推荐场景:
数据库上云
数据传输服务 DTS,数据迁移 small 3个月
推荐场景:
MySQL数据库上云
数据传输服务 DTS,数据同步 1个月
简介:

ZERO、前言

有关通信原理内容是在网上或百科整理得到,代码部分为本人所写,如果不当,还望指教。



一、Socket通信简介 

Android与服务器的通信方式主要有两种,一是Http通信,一是Socket通信。两者的最大差异在于,http连接使用的是“请求—响应方式”,即在请求时建立连接通道,当客户端向服务器发送请求后,服务器端才能向客户端返回数据。而Socket通信则是在双方建立起连接后就可以直接进行数据的传输,在连接时可实现信息的主动推送,而不需要每次由客户端想服务器发送请求。 那么,什么是socket?Socket又称套接字,在程序内部提供了与外界通信的端口,即端口通信。通过建立socket连接,可为通信双方的数据传输传提供通道。socket的主要特点有数据丢失率低,使用简单且易于移植。


1.1什么是Socket Socket
是一种抽象层,应用程序通过它来发送和接收数据,使用Socket可以将应用程序添加到网络中,与处于同一网络中的其他应用程序进行通信。简单来说,Socket提供了程序内部与外界通信的端口并为通信双方的提供了数据传输通道。


 1.2Socket的分类
 根据不同的的底层协议,Socket的实现是多样化的。本指南中只介绍TCP/IP协议族的内容,在这个协议族当中主要的Socket类型为流套接字(streamsocket)和数据报套接字(datagramsocket)。流套接字将TCP作为其端对端协议,提供了一个可信赖的字节流服务。数据报套接字使用UDP协议,提供数据打包发送服务。 下面,我们来认识一下这两种Socket类型的基本实现模型。


二、Socket 基本通信模型



三、Socket基本实现原理


 3.1基于TCP协议的Socket 
服务器端首先声明一个ServerSocket对象并且指定端口号,然后调用Serversocket的accept()方法接收客户端的数据。accept()方法在没有数据进行接收的处于堵塞状态。(Socketsocket=serversocket.accept()),一旦接收到数据,通过inputstream读取接收的数据。
  客户端创建一个Socket对象,指定服务器端的ip地址和端口号(Socketsocket=newSocket("172.168.10.108",8080);),通过inputstream读取数据,获取服务器发出的数据(OutputStreamoutputstream=socket.getOutputStream()),最后将要发送的数据写入到outputstream即可进行TCP协议的socket数据传输。
3.2基于UDP协议的数据传输 
服务器端首先创建一个DatagramSocket对象,并且指点监听的端口。接下来创建一个空的DatagramSocket对象用于接收数据(bytedata[]=newbyte[1024;]DatagramSocketpacket=newDatagramSocket(data,data.length)),使用DatagramSocket的receive方法接收客户端发送的数据,receive()与serversocket的accepet()类似,在没有数据进行接收的处于堵塞状态。
客户端也创建个DatagramSocket对象,并且指点监听的端口。接下来创建一个InetAddress对象,这个对象类似与一个网络的发送地址(InetAddressserveraddress=InetAddress.getByName("172.168.1.120")).定义要发送的一个字符串,创建一个DatagramPacket对象,并制定要讲这个数据报包发送到网络的那个地址以及端口号,最后使用DatagramSocket的对象的send()发送数据。*(Stringstr="hello";bytedata[]=str.getByte();DatagramPacketpacket=new DatagramPacket(data,data.length,serveraddress,4567);socket.send(packet);)


四、android 实现socket简单通信

前言:添加权限

[java]  view plain copy
  1. <!--允许应用程序改变网络状态-->    
  2. <uses-permission android:name="android.permission.CHANGE_NETWORK_STATE"/>    
  3.     
  4. <!--允许应用程序改变WIFI连接状态-->    
  5. <uses-permission android:name="android.permission.CHANGE_WIFI_STATE"/>    
  6.     
  7. <!--允许应用程序访问有关的网络信息-->    
  8. <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>    
  9.     
  10. <!--允许应用程序访问WIFI网卡的网络信息-->    
  11. <uses-permission android:name="android.permission.ACCESS_WIFI_STATE"/>    
  12.     
  13. <!--允许应用程序完全使用网络-->    
  14. <uses-permission android:name="android.permission.INTERNET"/>    

4.1使用TCP协议通信

android端实现:

[java]  view plain copy
  1.     protected void connectServerWithTCPSocket() {  
  2.   
  3.         Socket socket;  
  4.         try {// 创建一个Socket对象,并指定服务端的IP及端口号  
  5.             socket = new Socket("192.168.1.32"1989);  
  6.             // 创建一个InputStream用户读取要发送的文件。  
  7.             InputStream inputStream = new FileInputStream("e://a.txt");  
  8.             // 获取Socket的OutputStream对象用于发送数据。  
  9.             OutputStream outputStream = socket.getOutputStream();  
  10.             // 创建一个byte类型的buffer字节数组,用于存放读取的本地文件  
  11.             byte buffer[] = new byte[4 * 1024];  
  12.             int temp = 0;  
  13.             // 循环读取文件  
  14.             while ((temp = inputStream.read(buffer)) != -1) {  
  15.                 // 把数据写入到OuputStream对象中  
  16.                 outputStream.write(buffer, 0, temp);  
  17.             }  
  18.             // 发送读取的数据到服务端  
  19.             outputStream.flush();  
  20.   
  21.             /** 或创建一个报文,使用BufferedWriter写入,看你的需求 **/  
  22. //          String socketData = "[2143213;21343fjks;213]";  
  23. //          BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(  
  24. //                  socket.getOutputStream()));  
  25. //          writer.write(socketData.replace("\n", " ") + "\n");  
  26. //          writer.flush();  
  27.             /************************************************/  
  28.         } catch (UnknownHostException e) {  
  29.             e.printStackTrace();  
  30.         } catch (IOException e) {  
  31.             e.printStackTrace();  
  32.         }  
  33.   
  34.     }  

服务器端简单实现:

[java]  view plain copy
  1. public void ServerReceviedByTcp() {  
  2.     // 声明一个ServerSocket对象  
  3.     ServerSocket serverSocket = null;  
  4.     try {  
  5.         // 创建一个ServerSocket对象,并让这个Socket在1989端口监听  
  6.         serverSocket = new ServerSocket(1989);  
  7.         // 调用ServerSocket的accept()方法,接受客户端所发送的请求,  
  8.         // 如果客户端没有发送数据,那么该线程就停滞不继续  
  9.         Socket socket = serverSocket.accept();  
  10.         // 从Socket当中得到InputStream对象  
  11.         InputStream inputStream = socket.getInputStream();  
  12.         byte buffer[] = new byte[1024 * 4];  
  13.         int temp = 0;  
  14.         // 从InputStream当中读取客户端所发送的数据  
  15.         while ((temp = inputStream.read(buffer)) != -1) {  
  16.             System.out.println(new String(buffer, 0, temp));  
  17.         }  
  18.         serverSocket.close();  
  19.     } catch (IOException e) {  
  20.         e.printStackTrace();  
  21.     }  
  22. }  

4.2使用UDP协议通信

客户端发送数据实现:

[java]  view plain copy
  1. protected void connectServerWithUDPSocket() {  
  2.       
  3.     DatagramSocket socket;  
  4.     try {  
  5.         //创建DatagramSocket对象并指定一个端口号,注意,如果客户端需要接收服务器的返回数据,  
  6.         //还需要使用这个端口号来receive,所以一定要记住  
  7.         socket = new DatagramSocket(1985);  
  8.         //使用InetAddress(Inet4Address).getByName把IP地址转换为网络地址    
  9.         InetAddress serverAddress = InetAddress.getByName("192.168.1.32");  
  10.         //Inet4Address serverAddress = (Inet4Address) Inet4Address.getByName("192.168.1.32");    
  11.         String str = "[2143213;21343fjks;213]";//设置要发送的报文    
  12.         byte data[] = str.getBytes();//把字符串str字符串转换为字节数组    
  13.         //创建一个DatagramPacket对象,用于发送数据。    
  14.         //参数一:要发送的数据  参数二:数据的长度  参数三:服务端的网络地址  参数四:服务器端端口号   
  15.         DatagramPacket packet = new DatagramPacket(data, data.length ,serverAddress ,10025);    
  16.         socket.send(packet);//把数据发送到服务端。    
  17.     } catch (SocketException e) {  
  18.         e.printStackTrace();  
  19.     } catch (UnknownHostException e) {  
  20.         e.printStackTrace();  
  21.     } catch (IOException e) {  
  22.         e.printStackTrace();  
  23.     }    
  24. }  

客户端接收服务器返回的数据:

[java]  view plain copy
  1. public void ReceiveServerSocketData() {  
  2.     DatagramSocket socket;  
  3.     try {  
  4.         //实例化的端口号要和发送时的socket一致,否则收不到data  
  5.         socket = new DatagramSocket(1985);  
  6.         byte data[] = new byte[4 * 1024];  
  7.         //参数一:要接受的data 参数二:data的长度  
  8.         DatagramPacket packet = new DatagramPacket(data, data.length);  
  9.         socket.receive(packet);  
  10.         //把接收到的data转换为String字符串  
  11.         String result = new String(packet.getData(), packet.getOffset(),  
  12.                 packet.getLength());  
  13.         socket.close();//不使用了记得要关闭  
  14.         System.out.println("the number of reveived Socket is  :" + flag  
  15.                 + "udpData:" + result);  
  16.     } catch (SocketException e) {  
  17.         e.printStackTrace();  
  18.     } catch (IOException e) {  
  19.         e.printStackTrace();  
  20.     }  
  21. }  

服务器接收客户端实现:

[java]  view plain copy
  1. public void ServerReceviedByUdp(){  
  2.     //创建一个DatagramSocket对象,并指定监听端口。(UDP使用DatagramSocket)    
  3.     DatagramSocket socket;  
  4.     try {  
  5.         socket = new DatagramSocket(10025);  
  6.         //创建一个byte类型的数组,用于存放接收到得数据    
  7.         byte data[] = new byte[4*1024];    
  8.         //创建一个DatagramPacket对象,并指定DatagramPacket对象的大小    
  9.         DatagramPacket packet = new DatagramPacket(data,data.length);    
  10.         //读取接收到得数据    
  11.         socket.receive(packet);    
  12.         //把客户端发送的数据转换为字符串。    
  13.         //使用三个参数的String方法。参数一:数据包 参数二:起始位置 参数三:数据包长    
  14.         String result = new String(packet.getData(),packet.getOffset() ,packet.getLength());    
  15.     } catch (SocketException e) {  
  16.         e.printStackTrace();  
  17.     } catch (IOException e) {  
  18.         e.printStackTrace();  
  19.     }    
  20. }  


五、总结:

使用UDP方式android端和服务器端接收可以看出,其实android端和服务器端的发送和接收大庭相径,只要端口号正确了,相互通信就没有问题,TCP使用的是流的方式发送,UDP是以包的形式发送。



demo地址:http://download.csdn.net/detail/mad1989/5626975

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
Sqoop 企业级大数据迁移方案实战
Sqoop是一个用于在Hadoop和关系数据库服务器之间传输数据的工具。它用于从关系数据库(如MySQL,Oracle)导入数据到Hadoop HDFS,并从Hadoop文件系统导出到关系数据库。 本课程主要讲解了Sqoop的设计思想及原理、部署安装及配置、详细具体的使用方法技巧与实操案例、企业级任务管理等。结合日常工作实践,培养解决实际问题的能力。本课程由黑马程序员提供。
相关文章
|
3月前
|
缓存 监控 Java
Java Socket编程最佳实践:优化客户端-服务器通信性能
【6月更文挑战第21天】Java Socket编程优化涉及识别性能瓶颈,如网络延迟和CPU计算。使用非阻塞I/O(NIO)和多路复用技术提升并发处理能力,减少线程上下文切换。缓存利用可减少I/O操作,异步I/O(AIO)进一步提高效率。持续监控系统性能是关键。通过实践这些策略,开发者能构建高效稳定的通信系统。
100 1
|
2天前
|
安全 Android开发 Kotlin
Android经典实战之SurfaceView原理和实践
本文介绍了 `SurfaceView` 这一强大的 UI 组件,尤其适合高性能绘制任务,如视频播放和游戏。文章详细讲解了 `SurfaceView` 的原理、与 `Surface` 类的关系及其实现示例,并强调了使用时需注意的线程安全、生命周期管理和性能优化等问题。
21 7
|
3月前
|
Java 应用服务中间件 开发者
【实战指南】Java Socket编程:构建高效的客户端-服务器通信
【6月更文挑战第21天】Java Socket编程用于构建客户端-服务器通信。`Socket`和`ServerSocket`类分别处理两端的连接。实战案例展示了一个简单的聊天应用,服务器监听端口,接收客户端连接,并使用多线程处理每个客户端消息。客户端连接服务器,发送并接收消息。了解这些基础,加上错误处理和优化,能帮你开始构建高效网络应用。
264 10
|
3月前
|
IDE Java 开发工具
从零开始学Java Socket编程:客户端与服务器通信实战
【6月更文挑战第21天】Java Socket编程教程带你从零开始构建简单的客户端-服务器通信。安装JDK后,在命令行分别运行`SimpleServer`和`SimpleClient`。服务器监听端口,接收并回显客户端消息;客户端连接服务器,发送“Hello, Server!”并显示服务器响应。这是网络通信基础,为更复杂的网络应用打下基础。开始你的Socket编程之旅吧!
41 3
|
3月前
|
Java
Java Socket编程与多线程:提升客户端-服务器通信的并发性能
【6月更文挑战第21天】Java网络编程中,Socket结合多线程提升并发性能,服务器对每个客户端连接启动新线程处理,如示例所示,实现每个客户端的独立操作。多线程利用多核处理器能力,避免串行等待,提升响应速度。防止死锁需减少共享资源,统一锁定顺序,使用超时和重试策略。使用synchronized、ReentrantLock等维持数据一致性。多线程带来性能提升的同时,也伴随复杂性和挑战。
69 0
|
3月前
|
安全 Java 网络安全
Java Socket编程教程:构建安全可靠的客户端-服务器通信
【6月更文挑战第21天】构建安全的Java Socket通信涉及SSL/TLS加密、异常处理和重连策略。示例中,`SecureServer`使用SSLServerSocketFactory创建加密连接,而`ReliableClient`展示异常捕获与自动重连。理解安全意识,如防数据截获和中间人攻击,是首要步骤。通过良好的编程实践,确保网络应用在复杂环境中稳定且安全。
70 0
|
7天前
|
网络协议 C# 开发者
WPF与Socket编程的完美邂逅:打造流畅网络通信体验——从客户端到服务器端,手把手教你实现基于Socket的实时数据交换
【8月更文挑战第31天】网络通信在现代应用中至关重要,Socket编程作为其实现基础,即便在主要用于桌面应用的Windows Presentation Foundation(WPF)中也发挥着重要作用。本文通过最佳实践,详细介绍如何在WPF应用中利用Socket实现网络通信,包括创建WPF项目、设计用户界面、实现Socket通信逻辑及搭建简单服务器端的全过程。具体步骤涵盖从UI设计到前后端交互的各个环节,并附有详尽示例代码,助力WPF开发者掌握这一关键技术,拓展应用程序的功能与实用性。
20 0
|
8天前
|
存储 监控 数据库
Android经典实战之OkDownload的文件分段下载及合成原理
本文介绍了 OkDownload,一个高效的 Android 下载引擎,支持多线程下载、断点续传等功能。文章详细描述了文件分段下载及合成原理,包括任务创建、断点续传、并行下载等步骤,并展示了如何通过多种机制保证下载的稳定性和完整性。
16 0
|
2月前
|
SQL 弹性计算 关系型数据库
PolarDB产品使用问题之如何和ECS实例实现内网互通
PolarDB产品使用合集涵盖了从创建与管理、数据管理、性能优化与诊断、安全与合规到生态与集成、运维与支持等全方位的功能和服务,旨在帮助企业轻松构建高可用、高性能且易于管理的数据库环境,满足不同业务场景的需求。用户可以通过阿里云控制台、API、SDK等方式便捷地使用这些功能,实现数据库的高效运维与持续优化。
|
2月前
|
Java
如何在Java中实现多线程的Socket服务器?
在Java中,多线程Socket服务器能同时处理多个客户端连接以提升并发性能。示例代码展示了如何创建此类服务器:监听指定端口,并为每个新连接启动一个`ClientHandler`线程进行通信处理。使用线程池管理这些线程,提高了效率。`ClientHandler`读取客户端消息并响应,支持简单的文本交互,如发送欢迎信息及处理退出命令。
下一篇
DDNS