上周在项目遇到一个接口需求就是通讯系列必须是socket,所以在这篇博客里面我想谈谈自己在socket编程的时候遇到的一些问题。
其实在android里面实现一个socket通讯是非常简单的,我们只需要在代码里面实现一个Socket对象,同时在该对象里面传进一个ip/port,同时设置一些超时时间就可以了。代码如下:
public class SocketThread extends Thread { private String ip = "192.168.129.1"; private int port = 12344; private String TAG = "socket thread"; private int timeout = 60000; private int maxsize = 256; public Socket client = null; OutputStream out; InputStream in; public boolean isRun = true; Handler inHandler; Handler outHandler; Context context; private String tagTip = "===Send==="; public SocketThread(Handler handlerin, Handler handlerout, Context context) { inHandler = handlerin; outHandler = handlerout; this.context = context; Log.i(TAG, "创建线程socket"); } public void conn() { try { client = new Socket(ip, port); client.setSoTimeout(timeout); client.setTcpNoDelay(true); in = client.getInputStream(); out = client.getOutputStream(); } catch (UnknownHostException e) { Log.i(TAG, "连接错误UnknownHostException 重新获取"); e.printStackTrace(); conn(); } catch (IOException e) { Log.i(TAG, "连接服务器io错误"); e.printStackTrace(); } catch (Exception e) { Log.i(TAG, "连接服务器错误Exception" + e.getMessage()); e.printStackTrace(); } } @Override public void run() { conn(); String line = ""; while (isRun) { try { if (client != null) { Log.i(TAG, "2.检测数据"); byte[] temp = new byte[maxsize]; int size = 0; while ((size = in.read(temp)) > 0) { Log.i(TAG, "收到数据"); byte[] res = new byte[size]; System.arraycopy(temp, 0, res, 0, size); for (int i = 0; i < size; i++) { line += res[i] + " "; } Message msg = inHandler.obtainMessage(); msg.obj = line; inHandler.sendMessage(msg); } } else { Log.i(TAG, "没有可用连接"); conn(); } } catch (Exception e) { Log.i(TAG, "数据接收错误" + e.getMessage()); e.printStackTrace(); } } } public void Send(byte[] mess) { try { if (client != null) { out.write(mess); out.flush(); Log.i(tagTip, "发送成功"); Message msg = outHandler.obtainMessage(); msg.obj = mess; msg.what = 1; outHandler.sendMessage(msg); } else { Log.i(TAG, "client 不存在"); Message msg = outHandler.obtainMessage(); msg.obj = mess; msg.what = 0; outHandler.sendMessage(msg); Log.i(TAG, "连接不存在重新连接"); conn(); } } catch (Exception e) { Log.i(tagTip, "send error"); e.printStackTrace(); } finally { Log.i(tagTip, "发送完毕"); } } public void close() { try { if (client != null) { in.close(); out.close(); client.close(); } } catch (Exception e) { Log.i(TAG, "close err"); e.printStackTrace(); } } }
上面的代码我就简单的实现了一个基于tcp协议的socket通讯,发送的内容信息是byte[],当然如果大家想要使用udp协议或者发送string字符串的话,那么代码还需要重新修改。相信网上的资料很多,这里就不贴代码了。
其实我最想说的是,socket通讯的过程中,如果发送的是byte[]的话,那么就需要很小心的注意byte前后顺序,同时拼接的过程中如果还涉及一定的加密的话。那么我们还需要很小心的验证加密算法的正确性。
有一次我问过部门头为什么要使用socket通讯呢?他的回答很简单就是安全性高,无其他理由!
时间: 2024-10-06 21:27:53