之前做了一个安卓和设备通信的 Socket 封装模块，用于和设备进行数据交流，极大地解决了旧代码的复杂与混乱，并且提供了扩展性。接下来我会分好几篇博客慢慢介绍这个通信模块的各个部分，一步一步的将想要的设计，实现成具体的功能！
下面先简单介绍下 Socket 的使用。
Java 中的 socket 代码在 java.net 包下，可以在安卓官方文档下看看，不过是英文的：
https://developer.android.google.cn/reference/kotlin/java/net/Socket
https://developer.android.google.cn/reference/kotlin/java/net/ServerSocket
这里先简单地介绍下 Socket 客户端的用法，后面封装，毕竟和设备连接就靠客户端了。
public void onClick(View view){
new Thread(){
@Override
public void run() {
super.run();
try {
//1.创建监听指定服务器地址以及指定服务器监听的端口号
Socket socket = new Socket("111.111.11.11", 12306);//111.111.11.11为我这个本机的IP地址，端口号为12306.
//2.拿到客户端的socket对象的输出流发送给服务器数据
OutputStream os = socket.getOutputStream();
//写入要发送给服务器的数据
os.write(et.getText().toString().getBytes());
os.flush();
socket.shutdownOutput();
//拿到socket的输入流，这里存储的是服务器返回的数据
InputStream is = socket.getInputStream();
//解析服务器返回的数据
InputStreamReader reader = new InputStreamReader(is);
BufferedReader bufReader = new BufferedReader(reader);
String s = null;
final StringBuffer sb = new StringBuffer();
while((s = bufReader.readLine()) != null){
sb.append(s);
}
runOnUiThread(new Runnable() {
@Override
public void run() {
tv.setText(sb.toString());
}
});
//3、关闭IO资源（注：实际开发中需要放到finally中）
bufReader.close();
reader.close();
is.close();
os.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
学完 Socket 地简单用法，下面我们把它封装到 Service 里面去。下面是简化的代码，只说 Socket 连接和接收，其他东西在后续内容里面慢慢说：
public class ConnectService extends Service {
/** Socket相关，IP及端口号 **/
private String ip = "192.168.1.110";
private int port = 2050;
private int wait = 5000;
private Socket mSocket;
private Thread rxThread;
//初始化连接
public void setUpConnection() throws IOException {
//关闭已有 socket
stopExistSocket();
//创建新的 socket
createSocket();
//启动接收线程
startRxThread();
}
private void stopExistSocket() throws IOException {
if (mSocket != null) {
try {
mSocket.close();
mSocket = null;
} catch (IOException e) {
e.printStackTrace();
throw e;
}
}
}
private void createSocket() throws IOException {
SocketAddress sa = new InetSocketAddress(ip, port);
mSocket = new Socket();
try{
//设置信息及超时时间
mSocket.connect(sa, wait);
boolean isConnect = mSocket.isConnected();
mSocket.setKeepAlive(isConnect);
} catch(IOException e) {
mSocket = null;
throw e;
}
}
private void startRxThread() {
if (rxThread == null || !rxThread.isAlive()) {
rxThread = initReceiveThread();
rxThread.start();
}
}
//接受线程
private Thread initReceiveThread() {
return new Thread(new Runnable() {
@SuppressWarnings("ResultOfMethodCallIgnored")
@Override
public void run() {
try {
InputStream is;
while (mSocket != null) {
is = mSocket.getInputStream();
byte[] ackbuf = new byte[4]; //消息号
int ackrs = is.read(ackbuf, 0, 4);
if (ackrs < 0) {
Thread.sleep(1000);
continue;
}
//TODO 自行处理数据
...
}
}catch(IOException e) {
e.printStackTrace();
} catch(Exception e) {
e.printStackTrace();
}
}
});
}
}
实际这里就三步，关闭已有 socket、创建新的 socket、启动接收线程，都很简单。如果说有什么缺陷的话，就是没有合理的关闭流吧，有时间我再改改！
和设备连接用不到 Socket 服务端，所以这里我就写个简单的例子吧！封装了一个模拟的服务端，一看就懂：
public class SimulateUtil {
public static class SocketServer extends Thread {
private Socket remotePeer;
private SocketServer(Socket remotePeer) {
this.remotePeer = remotePeer;
}
public void run() {
try {
InputStream is = null;
while(remotePeer!= null) {
isHxz = remotePeer.getInputStream();
//写的很大，可以写成常量
byte[] ackbuf = new byte[2560];
int len = is.read(ackbuf, 0, 2560);
if (len <= 0) {
Thread.sleep(1000);
continue;
}
//假装过一会返回数据
Thread.sleep(1000L + ((int) (Math.random() * 10)) * 100L)；
remotePeer.getOutputStream().write("hey boy!".getBytes());
}
} catch(IOException e) {
e.printStackTrace();
} catch(Exception e) {
e.printStackTrace();
}
}
}
/**
* 启动模拟进程
*/
public static void startSimulate() {
new Thread(() -> {
try {
ServerSocket serverSocket = new ServerSocket(54321);
while (true) {
Socket remotePeer = serverSocket.accept();
new SocketServer(remotePeer).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}).start();
}
}
下面是使用方法，application 中启动就行：
SimulateUtil.startSimulate();
注意点：
这里的 IP 是本地地址（127.0.0.1）
端口号我们设置的 54321
关闭流什么的，可以参考下下面代码：
@Override
public void run() {
InputStreamReader reader = null;
BufferedReader bufReader = null;
OutputStream os = null;
try {
reader = new InputStreamReader(socket.getInputStream());
bufReader = new BufferedReader(reader);
String s = null;
StringBuffer sb = new StringBuffer();
while((s = bufReader.readLine()) != null){
sb.append(s);
}
System.out.println("服务器："+sb.toString());
//关闭输入流
socket.shutdownInput();
//返回给客户端数据
os = socket.getOutputStream();
os.write(("我是服务端,客户端发给我的数据就是："+sb.toString()).getBytes());
os.flush();
socket.shutdownOutput();
} catch (IOException e2) {
e2.printStackTrace();
} finally{
//关闭IO资源
if(reader != null){
try {
reader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if(bufReader != null){
try {
bufReader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if(os != null){
try {
os.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
好了，这里简单讲了一下 socket 的使用，用的都是 TCP 连接，因为这里是我写的《自定义安卓 socket 通信模块系列》的一部分，所以更多的偏向了具体的使用，如果读者想要更多的了解 socket 的使用，可以参考下面的文章，我觉得写的非常好：
https://www.jianshu.com/p/fb4dfab4eec1
另外，如果读者想继续了解我的《自定义安卓 socket 通信模块系列》文章，可以点击链接跳转查看哦！
end
文章浏览阅读3.2w次，点赞16次，收藏90次。对于这个问题我也是从网上找了很久，终于解决了这个问题。首先遇到这个问题，应该确认虚拟机能不能正常的上网，就需要ping 网关，如果能ping通说明能正常上网，不过首先要用命令route -n来查看自己的网关，如下图：第一行就是默认网关。现在用命令ping 192.168.1.1来看一下结果：然后可以看一下电脑上面百度的ip是多少可以在linux里面ping 这个IP，结果如下：..._linux桥接ping不通baidu
文章浏览阅读512次。小妹在这里已经卡了2-3天了，研究了很多人的文章，除了低版本api 17有成功外，其他的不是channel null 就是没反应 (channel null已解决)拜托各位大大，帮小妹一下，以下是我的程式跟 gradle, 我在这里卡好久又没有人可问(哭)public class MainActivity extends AppCompatActivit..._android 权限申请弹窗 横屏
文章浏览阅读1.4k次，点赞4次，收藏6次。valid padding（有效填充）：完全不使用填充。half/same padding（半填充/相同填充）：保证输入和输出的feature map尺寸相同。full padding（全填充）：在卷积操作过程中，每个像素在每个方向上被访问的次数相同。arbitrary padding（任意填充）：人为设定填充。..._cnn “相同填充”(same padding)
文章浏览阅读790次，点赞29次，收藏28次。手绘了下图所示的kafka知识大纲流程图（xmind文件不能上传，导出图片展现），但都可提供源文件给每位爱学习的朋友一个人可以走的很快，但一群人才能走的更远。不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人，都欢迎扫码加入我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习成长！[外链图片转存中…(img-Qpoc4gOu-1712656009273)][外链图片转存中…(img-bSWbNeGN-1712656009274)]
文章浏览阅读469次。Date对象取得年份有getYear和getFullYear两种方法经 测试var d=new Date;alert(d.getYear())在IE中返回 2009，在Firefox中会返回109。经查询手册，getYear在Firefox下返回的是距1900年1月1日的年份，这是一个过时而不被推荐的方法。而alert(d.getFullYear())在IE和FF中都会返回2009。因此，无论何时都应使用getFullYear来替代getYear方法。例如：2016年用 getFullYea_getyear和getfullyear
文章浏览阅读182次。Unix传奇(上篇) 陈皓 了解过去，我们才能知其然，更知所以然。总结过去，我们才会知道我们明天该如何去规划，该如何去走。在时间的滚轮中，许许多的东西就像流星一样一闪而逝，而有些东西却能经受着时间的考验散发着经久的魅力，让人津津乐道，流传至今。要知道明天怎么去选择，怎么去做，不是盲目地跟从今天各种各样琳琅满目前沿技术，而应该是去 —— 认认真真地了解和回顾历史。 Unix是目前还在存活的操作系_unix传奇pdf
文章浏览阅读308次。哈希算法：将字符串映射为数字形式，十分巧妙，一般运用为进制数，进制据前人经验，一般为131，1331时重复率很低，由于字符串的数字和会很大，所以一般为了方便，一般定义为unsigned long long,爆掉时，即为对 2^64 取模，可以对于任意子序列的值进行映射为数字进而进行判断入门题目链接：AC代码：#include<bits/stdc++.h>using na..._ac算法 哈希
文章浏览阅读952次，点赞13次，收藏27次。由于觉得Qt的编辑界面比较丑，所以想用vs2022的编辑器写Qt加MySQL的项目。_在vs中 如何装qt5sqlmysql模块
文章浏览阅读1k次。选择题题目：下面的哪个调研内容属于经济环境调研？（）题目：（）的目的就是加强与客户的沟通，它是是网络媒体也是网络营销的最重要特性。题目：4Ps策略中4P是指产品、价格、顾客和促销。题目：网络市场调研是目前最为先进的市场调研手段，没有任何的缺点或不足之处。题目：市场定位的基本参数有题目：市场需求调研可以掌握（）等信息。题目：在开展企业网站建设时应做好以下哪几个工作。（）题目：对企业网站首页的优化中，一定要注意下面哪几个方面的优化。（）题目：（）的主要作用是增进顾客关系，提供顾客服务，提升企业_画中画广告之所以能有较高的点击率,主要由于它具有以下特点
文章浏览阅读1k次，点赞2次，收藏5次。以爬取CSDN为例子：第一步：导入请求库第二步：打开请求网址第三步：打印源码import urllib.requestresponse=urllib.request.urlopen("https://www.csdn.net/?spm=1011.2124.3001.5359")print(response.read().decode('utf-8'))结果大概就是这个样子：好的，继续，看看打印的是什么类型的：import urllib.requestresponse=urllib.r_urlopen the read operation timed out
文章浏览阅读304次。修正sina.com/sina.cn邮箱获取不到联系人，并精简修改了其他邮箱代码，以下就是升级版版本的介绍：完整版本，整合了包括读取邮箱通讯录、MSN好友列表的的功能，目前读取邮箱通讯录支持如下邮箱：gmail(Y)、hotmail(Y)、 live(Y)、tom(Y)、yahoo(Y)(有点慢)、 sina(Y)、163(Y)、126(Y)、yeah(Y)、sohu(Y) 读取后可以发送邮件(完..._通讯录 应用读取 邮件 的相关
文章浏览阅读213次。云计算及虚拟化教程学习云计算、虚拟化和计算机网络的基本概念。此视频教程共2.0小时，中英双语字幕，画质清晰无水印，源码附件全课程英文名：Cloud Computing and Virtualization An Introduction百度网盘地址：https://pan.baidu.com/s/1lrak60XOGEqMOI6lXYf6TQ?pwd=ns0j课程介绍：https://www.aihorizon.cn/72云计算：概念、定义、云类型和服务部署模型。虚拟化的概念使用 Type-2 Hyperv_云计算与虚拟化技术 教改