之前做了一个安卓和设备通信的 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
文章浏览阅读4.3k次，点赞6次，收藏24次。1.首先选择一个天气插件，这里小编使用和风天气插件，见https://widget.qweather.com/2.小编这里写的是vue3.0的移动端项目，所以使用的是天气简单插件，根据自己的需求选择文字大小等，然后登陆或者不登陆直接生成代码，这里的key值不需要替换，直接用它生成的：3.打开vue项目，这里我们可以创建一个组件，小编这里在components中创建了weather.vue，如下代码：<template> <div class="weather"&._vue 天气组件
文章浏览阅读485次，点赞13次，收藏9次。本智慧综合管理是针对目前牙科诊所预约系统的实际需求，从实际工作出发，对过去的牙科诊所预约系统存在的问题进行分析，结合计算机系统的结构、概念、模型、原理、方法，在计算机各种优势的情况下，采用目前最流行的B/S结构、java技术MySQL数据库设计并实现的。本牙科诊所预约系统主要包括登录模块的实现、系统模块、管理员模块、医生模块、用户模块等多个模块。它帮助牙科诊所预约系统实现了信息化、网络化，通过测试，实现了系统设计目标，相比传统的管理模式，本系统合理的利用了网络数据资源，有效的减少了牙科诊所预约系统的经济投入
文章浏览阅读5.2k次。最近一个上线半年的爬虫挂了，错误信息如题，挂在了一个dataframe的merge操作上。仔细看了看源代码，这个merge操作非常简单，目的只是想看两个数据集中date(%Y-%m-%d %H-%M-%S)交集，然后再决定下一步的操作。首先怀疑数据量随着时间推移变得很大，得分块操作了。但是查了一下当下的数据量，两个dataframe都只有几十万行，数据量并不是很大，反而Jenkins serve..._file "pandas/_libs/join.pyx", line 104, in pandas._libs.join.left_outer_join memoryerror
文章浏览阅读1w次，点赞2次，收藏8次。有时候对于一些截图需要通过画框重点显示，用java代码在图片上画框的代码如下：package imagetest;import java.awt.Color;import java.awt.Graphics;import java.awt.image.BufferedImage;import java.io.File;import java.io.FileInputSt_java ffmpage图片 画框
文章浏览阅读2.2k次。一、概述打开你的手机，找到文件管理->分类->远程管理，点击启动服务，这样大家可以在局域网内使用电脑访问你手机上的文件了，当然你也可以设置账号和密码，防止“小人”共享你手机上的资源-.-，那如果自己动手，该如何实现这个小功能呢？二、实现1、导入相关的jar包，并在build.gradle添加相应的依赖，如图。2.创建服务配置文件在values文件夹下新建的xml文件，方便在代码中的引用..._android ftp 服务器
文章浏览阅读389次，点赞3次，收藏6次。探索Awesome ML Demos with iOS：让机器学习触手可及项目地址:https://gitcode.com/tucan9389/awesome-ml-demos-with-ios在这个数字化的时代，机器学习（ML）已经成为了软件开发的重要组成部分，尤其在移动应用中。Awesome ML Demos with iOS 是一个精心策划的GitHub项目，它汇集了众多以iOS平台为基...
文章浏览阅读612次。php常用方法总结/** * created by Tina * time 2015-1-6 10:31 * textarea中传入字符串的处理,返回数组,传入的字符串以换行分割; * 拆分,压缩空格,去除空值,去重复 ...bzoj 1097 [POI2007]旅游景点atr(最短路，状压DP)[题意] 给定一个n点m边的无向图,要求1开始n结束而且顺序经..._事务失败 服务器响应为5.7.1
文章浏览阅读508次。Android Studio常用快捷键1. Ctrl+D： 集合了复制和粘贴两个操作，如果有选中的部分就复制选中的部分，并在选中部分的后面粘贴出来，如果没有选中的部分，就复制光标所在的行，并在此行的下面粘贴出来。2. Ctrl+空格： 输入代码时按此组合键会列出与之相匹配的类、方法名、成员变量等，起智能提示的作用。在编辑XML文件一样有用。3. Ctrl+向下箭头 或Ctr_寻求升级帮助，emu i com斜杠emot，ion do w
文章浏览阅读397次。本文是区块链共识算法的综述论文“A Review on Consensus Algorithm of Blockchain”的阅读笔记，论文对区块链的共识算法进行了全面的描述，但是受限于时代因素，里面的一些内容有一定错误或过时，例如PoS+PoW被分类为PoS、认为PoW具有无限的可扩展性等。_区块链共识算法论文
文章浏览阅读361次。在.net 3.5的情况下前台JQuery做Ajax的时候，服务器端（1）可以调用aspx.cs 中声明带有[WebMehtod]的public static 的方法(不需要自己手动添加web.config的配置)（2）可以调用 *.asmx (web服务) 里面加了[webmethod]的方法（不能写静态,写静态就调用不到了）需要在asmx里面 去掉 [System.Web.Scri..._asmx webmethod语法
文章浏览阅读1.4w次，点赞15次，收藏76次。GUILayoutGUILayoutOption基本每个控件方法都有一个可选参数是GUILayoutOption[] Options 这是一个可以控制组件大小之类的选项,在GUILayout类中共有8个。GUILayout.Height()GUILayout.Width()GUILayout.MaxHeight()GUILayout..._editorguilayout.popup
文章浏览阅读874次。学习目标：提示：这里可以添加学习目标例如： 一周掌握 Java 入门知识学习内容：提示：这里可以添加要学的内容例如：搭建 Java 开发环境掌握 Java 基本语法掌握条件语句掌握循环语句学习时间：提示：这里可以添加计划学习的时间例如：周一至周五晚上 7 点—晚上9点周六上午 9 点-上午 11 点周日下午 3 点-下午 6 点学习产出：提示：这里统计学习计划的总量例如： 技术笔记 2 遍 CSDN 技术博客 3 篇 习的 vlog 视频 1