java之socket的OOBInline和UrgentData和发送心跳包研究

UrgentData可以理解为紧急发送数据方式,如果我们客户端先用write方法写入数据,再用UrgentData发送数据,再去执行flush操作,我们可以得到服务端先打印UrgentData发送的数据,然后再打印write写入的数据。

客户端代码实现:

package com.chenyu.string.cn;import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;public class ClientTest {public static Socket socket;public static final String LocalHOST = "127.0.0.1";public static final int PORT = 1234;public static void main(String[] args) {Client(LocalHOST, PORT);}public static void Client(String address, int port) {try {socket = new Socket(address, port);} catch (Exception e) {System.out.println("connection reset");return;}if (socket != null && socket.isConnected()) {try {socket.setOOBInline(true);OutputStream out = socket.getOutputStream();OutputStreamWriter outWriter = new OutputStreamWriter(out);outWriter.write(67); // 向服务器发送字符"C"outWriter.write("hello world\r\n");socket.sendUrgentData(65); // 向服务器发送字符"A"socket.sendUrgentData(322); // 向服务器发送字符"B"outWriter.flush();socket.sendUrgentData(214); // 向服务器发送汉字”中”socket.sendUrgentData(208);socket.sendUrgentData(185); // 向服务器发送汉字”国”socket.sendUrgentData(250);socket.close();} catch (Exception e) {System.out.println("has throw exception");e.printStackTrace();} finally {try {if (socket != null) {socket.close();}} catch (IOException e) {System.out.println("socket close fail");}}} else {System.out.println("socket is null or socket connect fail");}}
}
 

服务端代码实现:

package com.chenyu.string.cn;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;public class TestInline {public static ServerSocket serverSocket;public static Socket socket;public static void main(String[] args) {try {serverSocket = new ServerSocket(1234);} catch (IOException e1) {System.out.println("serverSocket is fail");return;}System.out.println("服务器已经启动,端口号:1234");while (true) {try {socket = serverSocket.accept();socket.setOOBInline(true);InputStream in = socket.getInputStream();InputStreamReader inReader = new InputStreamReader(in);BufferedReader bReader = new BufferedReader(inReader);String result;while ((result = bReader.readLine()) != null) {System.out.println(result);}
//				char [] cha = new char[1024];
//				int len = inReader.read(cha);
//				System.out.println(new String(cha,0,len));socket.close();} catch (Exception e){System.out.println("read data fail");} finally {if (socket != null) {try {socket.close();} catch (IOException e) {System.out.println("socket close fail");}}}}}
}	socket = serverSocket.accept();socket.setOOBInline(true);InputStream in = socket.getInputStream();InputStreamReader inReader = new InputStreamReader(in);BufferedReader bReader = new BufferedReader(inReader);String result;while ((result = bReader.readLine()) != null) {System.out.println(result);}
//				char [] cha = new char[1024];
//				int len = inReader.read(cha);
//				System.out.println(new String(cha,0,len));socket.close();} catch (Exception e){System.out.println("read data fail");} finally {if (socket != null) {try {socket.close();} catch (IOException e) {System.out.println("socket close fail");}}}}}
}
 

运行结果(先运行服务端,后运行客户端):

服务器已经启动,端口号:1234
ABChello world
中国
说明使用sendUrgentData方法发送数据后,系统会立即将这些数据发送出去;而使用write发送数据,必须要使用flush方法才会真正发送数据。
在使用setOOBInline方法打开SO_OOBINLINE选项时要注意是必须在客户端和服务端程序同时使用setOOBInline方法打开这个选项,否则无法命名用sendUrgentData来发送数据。


总结:

我们还可以通过socket.sendUrgentData(0xff);来检测是否与服务端连通,和ping IP 效果差不多,其它的socket.isConnected() socket.isOutputShutdown()都是本地检测,我们上面socket发送数据,如果在安卓客户端,我们可以用这个来发送心跳包,
类似上面客户端的代码,通过后台下发的IP和端口配置,开启线程,out.write(data),通过handler.postDelay(Runable, delayTime)发送心跳包给服务端。

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/292420.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

context:annotation-config 跟 context:component-scan诠释及区别

<context:annotation-config> 是用于激活那些已经在spring容器里注册过的bean&#xff08;无论是通过xml的方式还是通过package sanning的方式&#xff09;上面的注解。 <context:component-scan>除了具有<context:annotation-config>的功能之外&#xff0c;…

python 读行为数组_python将多列文件读入数组

我在读一个文件&#xff0c;它看起来像&#xff1a;Protein in water5826300LEU N 2945 7.972 16.153 13.055 -0.0183 0.4861 -0.4376300LEU H 2946 8.006 16.194 13.139 1.5894 1.3176 -1.4422300LEU CA 2947 8.017 16.020 13.016 0.1247 0.7136 -0.1096300LEU CB 2948 8.157 …

01背包初始化的细节问题与循环下限的改进

转自&#xff1a;背包久讲 Tianyi Cui 初始化的细节问题 我们看到的求最优解的背包问题题目中&#xff0c;事实上有两种不太相同的问法。有的题目要求“恰好装满背包”时的最优解&#xff0c;有的题目则并没有要求必须把背包装满。一种区别这两种问法的实现方法是在初始化的时候…

为什么中国这么多高薪程序员,开发不出Java, Typescript, Python, Rust, Node.js这些基础设施?...

近日&#xff0c;有人在网上问了这个问题&#xff0c;引起了网友热议&#xff1a;为什么中国这么多高薪程序员&#xff0c;开发不出Java&#xff0c;Typescript, Python, Rust, Node.js这些基础设施&#xff1f;对这个问题&#xff0c;大家从不同角度发表了自己的看法。有人说&…

字符串之从规定的字符串中根据下标得到字符

题目: 例如给规定字符串str = "a_3_b_4_c_5",给定下标4,会得到字符b str = "a_3_b_4_c_5" 就意味着字符串是str = "aaabbbbccccc"; 然后下标4,就会得到字符‘b’ 代码实现: package com.chenyu.string.cn;import java.util.Arrays;public…

当你女朋友第一次来你家会发生什么?

1 五一假期你都怎么过&#xff1f;▼2 万一实现了呢&#xff08;via.月半土荅塔&#xff09;▼3 你下周三就见不到李总了&#xff01;▼4 对不起&#xff0c;但真的很好笑▼5 女朋友第一次来我家做饭▼6 还我美女&#xff01;&#xff01;&#xff01;▼7 走他们的路&…

Linux常用C函数-接口处理篇(网络通信函数)

接口处理篇accept&#xff0c;bind&#xff0c;connect&#xff0c;endprotoent&#xff0c;endservent&#xff0c;getsockopt&#xff0c;htonl&#xff0c;htons&#xff0c;inet_addr&#xff0c;inet_aton&#xff0c;inet_ntoa&#xff0c;listen&#xff0c;ntohl&#…

hdu 5108

//题意是给一个数N,然后让你求M,使得N/M为素数,并且M的值最小//思路呢,大概有两种,一个是遍历素数求解的,不过数据太大不现实//另外一种就是质因数求解,for循环是遍历质因数,然后while循环是剔除相同的质因数//最后你可以判定剩下来的如果非1,则是最大素数....#include <ios…

跟随大数据旅行

2019独角兽企业重金招聘Python工程师标准>>> 跟随大数据旅行 这是一本短小而精悍的书&#xff0c;不需要花费太多时间就能够让读者弄清 楚大数据到底是什么&#xff0c;还能帮助读者了解大数据的来龙去脉以及未来大 数据对各行各业带来的影响与作用。大数据将带来新…

利用for循环调用插入方法批量插入 一条失败_算法与数据结构(1):基础部分——以插入排序为例...

本文将会以插入排序为例&#xff0c;介绍算法与数据结构的基础部分。插入排序排序可以说是整个算法中最为基础&#xff0c;最为重要的一部分&#xff0c;而插入排序正是排序算法中最简单的一种解决办法。什么是排序问题&#xff1f;输入&#xff1a;n个数的一个序列 。输出&…

MD5计算,一个扩展类,哪里都能用

最近有同学问到如何计算一个字节数组的MD5值&#xff0c;现在分享一个扩展类&#xff0c;有了它&#xff0c;MD5计算再也不用其他了。先看示例&#xff1a;string s "hello world";var s_md5 s.ToMD5();string f "C:\Windows\explorer.exe";var f_md5 f…

字符串之翻转字符串

题目: 给定一个字符类型的数组chas,请在单词间做逆序调整,只要做到单词顺序即可,对空格的位置没有特别要求。 例如: 如果把chas看作字符串为“dog loves pig”,调整成“pig loves dog”. 如果把chas看作字符串为“Im a student.”,调整成“student. a Im”. 代码: pac…

noi 4982 踩方格

题目链接&#xff1a;http://noi.openjudge.cn/ch0206/4982/ 深搜很好写。 DP&#xff1a;O(n) d[i] 为走 I 不的方案数&#xff0c; l[i],r[i],u[i]为第一步走 左&#xff0c;右&#xff0c;上&#xff0c;共走 i 步的方案数。(u[i] d[i-1]) d[i] l[i] r[i] u[i] l[i-1] …

VB6之GIF分解

原文链接&#xff1a;http://hi.baidu.com/coo_boi/item/1264a64172fe8dec1f19bc08 还是找了个C的翻译下&#xff0c;原文链接&#xff1a;http://www.360doc.com/content/05/1122/15/1894_34348.shtml GDI的函数声明 我就不放上了&#xff0c;网上有个做好的GDI公共模块。 Pri…

MindFusion Pack for ASP.NET发布v2013.R2

在MindFusion.Diagramming for WebForms中&#xff1a;导入OpenOffice Draw文件新的DrawImporter类允许你通过OpenOffice Draw Vector图形编辑器导入后缀为*.odg的文件。只需添加一个引用到MindFusion.Diagramming.Import.Draw.dll组即可。你还可以使用导入法的多种重载将OpenO…

python中的常量可以修改吗_python实现不可修改的常量

因为种种原因&#xff0c;Python并未提供如C/C/Java一样的const修饰符&#xff0c;换言之&#xff0c;python中没有常量&#xff0c;至少截止2015年年末&#xff0c;还没有这个打算。Python程序一般通过约定俗成的变量名全大写的形式来表示这是一个常量&#xff0c;但是这终究不…

字符串之数组中两个字符串的最小距离

题目: 给定一个字符串数组strs, 再给定两个字符串str1和str2,返回在strs中str1和str2的最小距离,如果str1和str2为null,或者不再strs中,都返回-1 列如: strs = {"1","3","3","2","3","1","3"} ,…

【翻译】C#表达式中的动态查询

当您使用LINQ来处理数据库时&#xff0c;这种体验是一种神奇的体验&#xff0c;对吗&#xff1f;你把数据库实体像一个普通的收集&#xff0c;使用Linq中像Where&#xff0c;Select或者 Take&#xff0c;这些简单的使用就能让代码可用了。但是&#xff0c;让我们考虑一下这里是…