当前位置:首页 > 芯闻号 > 充电吧
[导读]先说明一下粘包的概念: 发送时是两个单独的包、两次发送,但接收时两个包连在一起被一次接收到。在以前 WinCE 下 Socket 编程,确实也要处理粘包的问题,没想到在 Android 下也遇到了。首

先说明一下粘包的概念: 发送时是两个单独的包、两次发送,但接收时两个包连在一起被一次接收到。

在以前 WinCE 下 Socket 编程,确实也要处理粘包的问题,没想到在 Android 下也遇到了。
首先想从发送端能否避免这样的问题,例如: (1) 调用强制刷数据完成发送的函数;(2) 设置发送超时。
1 先试了调用 flush() 函数,但运行后现象依旧
2 设置发送超时是 Windows 平台的做法,但在 Android 平台下是否有类似的设置呢?
查看 Socket 类的实现代码:java.net.socket socket.class 文件后发现,还是有函数可以完成这样的设置的。请看如下函数和变量的说明:

/**
 * Sets this socket's {@link SocketOptions#TCP_NODELAY} option.
 */
public void setTcpNoDelay(boolean on) throws SocketException {
    checkOpenAndCreate(true);
    impl.setOption(SocketOptions.TCP_NODELAY, Boolean.valueOf(on));
}


/**
 * This boolean option specifies whether data is sent immediately on this socket.
 * As a side-effect this could lead to low packet efficiency. The
 * socket implementation uses the Nagle's algorithm to try to reach a higher
 * packet efficiency if this option is disabled.
 */
public static final int TCP_NODELAY = 1;


一般情况下,只需要调用如下的代码即可:

public Socket clientSocket = null;
// 实例化对象并连接到服务器
clientSocket = new Socket("172.25.103.1",12589);


不用做任何设置就可以完成与服务器/客户端的通讯,刚开始我也是这样做的。所以,遇到了上面的问题。

// 发送数据包,默认为 false,即客户端发送数据采用 Nagle 算法;
// 但是对于实时交互性高的程序,建议其改为 true,即关闭 Nagle 算法,客户端每发送一次数据,无论数据包大小都会将这些数据发送出去
clientSocket.setTcpNoDelay(true);


看以下较完整的 Socket 初始化与设置过程:

/* * * * * * * * * * 客户端 Socket 通过构造方法连接服务器 * * * * * * * * * */
try {
  // 客户端 Socket 可以通过指定 IP 地址或域名两种方式来连接服务器端,实际最终都是通过 IP 地址来连接服务器
  // 新建一个Socket,指定其IP地址及端口号
  Socket clientSocket = new Socket("172.25.103.1",12589);
  // 客户端socket在接收数据时,有两种超时:1. 连接服务器超时,即连接超时;2. 连接服务器成功后,接收服务器数据超时,即接收超时
  // 设置 socket 读取数据流的超时时间
  clientSocket.setSoTimeout(5000);
  // 发送数据包,默认为 false,即客户端发送数据采用 Nagle 算法;
  // 但是对于实时交互性高的程序,建议其改为 true,即关闭 Nagle 算法,客户端每发送一次数据,无论数据包大小都会将这些数据发送出去
  clientSocket.setTcpNoDelay(true);
  // 设置客户端 socket 关闭时,close() 方法起作用时延迟 30 秒关闭,如果 30 秒内尽量将未发送的数据包发送出去
  clientSocket.setSoLinger(true, 30);
  // 设置输出流的发送缓冲区大小,默认是4KB,即4096字节
  clientSocket.setSendBufferSize(4096);
  // 设置输入流的接收缓冲区大小,默认是4KB,即4096字节
  clientSocket.setReceiveBufferSize(4096);
  // 作用:每隔一段时间检查服务器是否处于活动状态,如果服务器端长时间没响应,自动关闭客户端socket
  // 防止服务器端无效时,客户端长时间处于连接状态
  clientSocket.setKeepAlive(true);
  // 客户端向服务器端发送数据,获取客户端向服务器端输出流
  OutputStream osSend = clientSocket.getOutputStream();
  OutputStreamWriter osWrite = new OutputStreamWriter(osSend);
  BufferedWriter bufWrite = new BufferedWriter(osWrite);
  // 代表可以立即向服务器端发送单字节数据
  clientSocket.setOOBInline(true);
  // 数据不经过输出缓冲区,立即发送
  clientSocket.sendUrgentData(0x44);//"D"
  // 向服务器端写数据,写入一个缓冲区
  // 注:此处字符串最后必须包含“rnrn”,告诉服务器HTTP头已经结束,可以处理数据,否则会造成下面的读取数据出现阻塞
  // 在write() 方法中可以定义规则,与后台匹配来识别相应的功能,例如登录Login() 方法,可以写为write("Login|LeoZheng,0603 rnrn"),供后台识别;
  bufWrite.write("Login|LeoZheng,0603 rnrn");
  // 发送缓冲区中数据 - 前面说调用 flush() 无效,可能是调用的方法不对吧!
  bufWrite.flush();
}
catch (UnknownHostException e) {
	e.printStackTrace();
} catch (IOException e) {
	e.printStackTrace();
}


/* * * * * * * * * * Socket 客户端读取服务器端响应数据 * * * * * * * * * */
try {
  // serverSocket.isConnected 代表是否连接成功过
  // 判断 Socket 是否处于连接状态
  if(true == serverSocket.isConnected() && false == serverSocket.isClosed()) {
  	// 客户端接收服务器端的响应,读取服务器端向客户端的输入流
  	InputStream isRead = serverSocket.getInputStream();
  	// 缓冲区
  	byte[] buffer = new byte[isRead.available()];
  	// 读取缓冲区
  	isRead.read(buffer);
  	// 转换为字符串
  	String responseInfo = new String(buffer);
  	// 日志中输出
  	Log.i("Socket Server", responseInfo);
  }
  // 关闭网络
  serverSocket.close();
}
catch (UnknownHostException e) {
	e.printStackTrace();
} catch (IOException e) {
	e.printStackTrace();
}


/* * * * * * * * * * Socket 客户端通过 connect 方法连接服务器 * * * * * * * * * */
try {
  Socket serverSocket = new Socket();
  // 使用默认的连接超时
  serverSocket.connect(new InetSocketAddress("172.25.103.1",12589));		// 连接超时 3 秒: serverSocket.connect(new InetSocketAddress("172.25.103.1",12589),3000);
  
  // 关闭 socket
  serverSocket.close();
}
catch (UnknownHostException e) {
	e.printStackTrace();
} catch (IOException e) {
	e.printStackTrace();
}


最后说明一点: 无论 Socket 如何设置,接收方是一定要处理粘包的问题的。即在接收时,对接收到的数据进行分析,看是否存在数据不全或粘包的现象。

本站声明: 本文章由作者或相关机构授权发布,目的在于传递更多信息,并不代表本站赞同其观点,本站亦不保证或承诺内容真实性等。需要转载请联系该专栏作者,如若文章内容侵犯您的权益,请及时联系本站删除。
换一批
延伸阅读

9月2日消息,不造车的华为或将催生出更大的独角兽公司,随着阿维塔和赛力斯的入局,华为引望愈发显得引人瞩目。

关键字: 阿维塔 塞力斯 华为

加利福尼亚州圣克拉拉县2024年8月30日 /美通社/ -- 数字化转型技术解决方案公司Trianz今天宣布,该公司与Amazon Web Services (AWS)签订了...

关键字: AWS AN BSP 数字化

伦敦2024年8月29日 /美通社/ -- 英国汽车技术公司SODA.Auto推出其旗舰产品SODA V,这是全球首款涵盖汽车工程师从创意到认证的所有需求的工具,可用于创建软件定义汽车。 SODA V工具的开发耗时1.5...

关键字: 汽车 人工智能 智能驱动 BSP

北京2024年8月28日 /美通社/ -- 越来越多用户希望企业业务能7×24不间断运行,同时企业却面临越来越多业务中断的风险,如企业系统复杂性的增加,频繁的功能更新和发布等。如何确保业务连续性,提升韧性,成...

关键字: 亚马逊 解密 控制平面 BSP

8月30日消息,据媒体报道,腾讯和网易近期正在缩减他们对日本游戏市场的投资。

关键字: 腾讯 编码器 CPU

8月28日消息,今天上午,2024中国国际大数据产业博览会开幕式在贵阳举行,华为董事、质量流程IT总裁陶景文发表了演讲。

关键字: 华为 12nm EDA 半导体

8月28日消息,在2024中国国际大数据产业博览会上,华为常务董事、华为云CEO张平安发表演讲称,数字世界的话语权最终是由生态的繁荣决定的。

关键字: 华为 12nm 手机 卫星通信

要点: 有效应对环境变化,经营业绩稳中有升 落实提质增效举措,毛利润率延续升势 战略布局成效显著,战新业务引领增长 以科技创新为引领,提升企业核心竞争力 坚持高质量发展策略,塑强核心竞争优势...

关键字: 通信 BSP 电信运营商 数字经济

北京2024年8月27日 /美通社/ -- 8月21日,由中央广播电视总台与中国电影电视技术学会联合牵头组建的NVI技术创新联盟在BIRTV2024超高清全产业链发展研讨会上宣布正式成立。 活动现场 NVI技术创新联...

关键字: VI 传输协议 音频 BSP

北京2024年8月27日 /美通社/ -- 在8月23日举办的2024年长三角生态绿色一体化发展示范区联合招商会上,软通动力信息技术(集团)股份有限公司(以下简称"软通动力")与长三角投资(上海)有限...

关键字: BSP 信息技术
关闭
关闭