android利用socket与java后台交互的设计与实现

对于初学者，Android的网络通信是大家都喜欢但是又会感觉很难处理的模块。特别数据传输方面，初学者很可能犯一个很容易犯的错误，就是客户端通过字节数组或者对象与服务器端交换数据，但最后会发现它们都很不可行（用字节流时在与服务器端交互数据的时候很难操作控制，很难让服务器端知道什么时候应该开始下一步的处理；用对象交换数据的时候，交换要求是客户端和服务器端必须有类名、包名、内容完全相同的类，这样很难做到跨语言的通讯）。因此我采用了字符流的形式传送数据并对网络的访问做了一系列的封装，希望能够帮助到你。废话就不多说了，开始切入正题吧。

客户端与服务器端交互主要的思想为：客户端把数据转化为JSON格式的字符串再发给服务器端（字符串主要包含两个部分：操作码，数据。转化方式为：把数据传入到模板类的对象中，通过FastJson把对象转化为字符串）。服务器端接收到字符串之后再把字符串转化为模板类的对象（转化方式为：先通过FastJson把字符串转化为JSON对象格式的数据，再把JSON对象转化为模板类的对象），服务器端根据操作码来做不同的处理，处理之后把数据封装到模板类的对象中，FastJson再把模板类的对象转化为字符串传给客户端，客户端接收到字符串数据之后再把字符串数据转化为模板类的对象（转化方式同上），客户端再通过模板类做相应的处理。

客户端发送给服务器端的数据主要格式为：

{code:1，data:[{}，{}]
}

服务器端发送给客户端的数据主要格式为：

{ok:true,data:{}
}

或者

{ok:true,data:[{},{}]
}

看起来是不是很简单呢，那么开始代码讲解了吧。

安卓端：
主要使用到了如下几个类：
数据请求模板类RequestMessage（主要用来封装发给服务器端的数据）：

package com.szhushou.ssp.connection;import java.util.Map;public class RequestMessage {private Integer code;//操作码private Map<String, String> data;//传送给服务器端的数据public void setCode(Integer code) {this.code = code;}public void setData(Map<String, String> data) {this.data = data;}public Integer getCode() {return code;}public Map<String, String> getData() {return data;}
}

网络传输核心类SocketConnection（主要用来封装最基本的数据传输类）：

package com.szhushou.ssp.connection;import android.util.Log;import com.alibaba.fastjson.JSON;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;public class SocketConnection {private final static String TAG = "SocketConnection";private final static String END = "#end#";//用来结束发送的字符串private Socket client = null;private BufferedReader ois = null;private PrintStream oos = null;public SocketConnection(String ip, int host) throws IOException {client = new Socket(ip, host);oos = new PrintStream(client.getOutputStream());ois = new BufferedReader(new InputStreamReader(client.getInputStream()));}public String requestData(RequestMessage messageOut) throws IOException {String result;String json = JSON.toJSONString(messageOut);sendString(oos, json);result = readString(ois);Log.i(TAG, result);oos.close();ois.close();if (!client.isClosed()) {client.close();}return result;}/***用来读取输入流的内容*/private String readString(BufferedReader ois) throws IOException {String result;String bufferText;StringBuffer resultBuffer = new StringBuffer();while (!(bufferText = ois.readLine()).equals(END)) {resultBuffer.append(bufferText);}result = resultBuffer.toString();return result;}/***用来写入数据到输出流*/private void sendString(PrintStream out, String text) {out.println(text);out.println(END);out.flush();}
}

业务逻辑的数据传输类Connection（主要用来对SocketConnection 进行进一步的封装处理，用来实现Android的网络线程异步处理，可以通过继承Connection类实现getData方法来做其他数据，如String格式的数据处理）：

package com.szhushou.ssp.connection;import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;import com.alibaba.fastjson.JSONObject;import java.io.IOException;/*** Created by xiaofeng on 2016-04-19.*/
public abstract class Connection {private final static String TAG="Connection";private String ip;private int host;public Connection(String ip,int host){this.ip=ip;this.host=host;}/*** 发送数据给服务器端* @param requestData 请求的数据* @param resultClass 接收的数据类的类型* @param successListener 访问数据成功的回调函数* @param failListener 访问数据失败的回调函数，失败主要包含两种失败，网络通信失败和服务器返回的ok值为false的失败，如果是网络通信失败onFile会返回IOException，如果是ok为false onFile会返回DataNullException* @param <T> 模板类*/public <T> void sendRequest(final RequestMessage requestData,Class<T> resultClass,SuccessListener<T> successListener,FailListener failListener){final MyHandler<T> handler=new MyHandler<T>(successListener,failListener,resultClass);new Thread(){@Overridepublic void run(){boolean ok;String result;try {result = new SocketConnection(ip,host).requestData(requestData);ok=true;} catch (IOException e) {e.printStackTrace();result="";ok=false;}Bundle bundle=new Bundle();bundle.putBoolean("ok", ok);bundle.putString("data", result);Message message=new Message();message.setData(bundle);handler.sendMessage(message);}}.start();}/***用来处理异步通讯*/private class MyHandler<T> extends Handler {private SuccessListener<T> mSuccessListener;private FailListener mFailListener;private Class<T> mClass;public MyHandler(SuccessListener<T> successListener,FailListener failListener, Class<T> clazz) {super();this.mSuccessListener = successListener;this.mFailListener=failListener;this.mClass = clazz;}@Overridepublic void handleMessage(Message msg) {super.handleMessage(msg);Bundle data = msg.getData();String result = data.getString("data");boolean ok = data.getBoolean("ok");Log.i(TAG,result);if(ok==true) {JSONObject jsonObject=JSONObject.parseObject(result);boolean isOk=jsonObject.getBoolean("ok");if(isOk==true) {T resultData = getData(jsonObject,mClass);mSuccessListener.onResponse(resultData);}else {String remindText=jsonObject.getString("data");if(remindText==null) {mFailListener.onFile(new DataNullException());}else {mFailListener.onFile(new DataNullException(remindText));}}}else {mFailListener.onFile(new IOException());}}}/*** ok值为false抛出的提示异常，如果服务器端未传递值给data，则调用getMessage返回的值是null，如果服务器端有传递值给data，则调用getMessage返回的值为data对应的值*/public class DataNullException extends Exception{private String message;public DataNullException(){super();}public DataNullException(String detailMessage){super(detailMessage);message=detailMessage;}@Overridepublic String getMessage() {return message;}}/*** 该方法用来给继承实现，主要是为了去处理结果数据为数组或者为单一对象问题* @param jsonObject 封装有数据的Json* @param mClass 返回结果的类型* @param <T> 结果的类型* @return 转化后的结果*/protected abstract <T> T getData(JSONObject jsonObject,Class<T> mClass);public interface SuccessListener<T>{public void onResponse(T t);}public interface FailListener{public void onFile(Exception e);}
}

Conection的扩展类，主要用来处理数据返回为单一对象的操作类ObjectConnection

package com.szhushou.ssp.connection;import com.alibaba.fastjson.JSONObject;/*** Created by xiaofeng on 2016-04-19.*/
public class ObjectConnection extends Connection {public ObjectConnection(String ip, int host) {super(ip, host);}@Overrideprotected <T> T getData(JSONObject jsonObject,Class<T> mClass){return JSONObject.toJavaObject(jsonObject.getJSONObject("data"), mClass);}
}

Conection的扩展类，主要用来处理数据返回为对象数组的操作类ArrayConnection：

package com.szhushou.ssp.connection;import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;/*** Created by xiaofeng on 2016-04-19.*/
public class ArrayConnection extends Connection {public ArrayConnection(String ip, int host) {super(ip, host);}@Overrideprotected  <T> T getData(JSONObject jsonObject, Class<T> mClass) {return JSONArray.toJavaObject(jsonObject.getJSONArray("data"), mClass);}
}

核心类已经写完了，如果不能理解也不要紧，只需要会调用就可以了，以下是用于安卓端调用的核心方法。

try {Map<String, String> map = new HashMap<String, String>();map.put("name", "client");map.put("metter","hello world！");RequestMessage requestMessage = new RequestMessage();requestMessage.setCode(1);requestMessage.setData(map);new ObjectConnection("192.168.191.1",6000).sendRequest(requestMessage, ResponseContent.class, new Connection.SuccessListener<ResponseContent>() {@Overridepublic void onResponse(ResponseContent responseContent) {//TODO 用来处理接收到的数据，数据都封装到resposeContent中了}}, new Connection.FailListener() {@Overridepublic void onFile(Exception e) {Toasts.showShort("出现异常，识别失败");//TODO Toasts是为了简写Toast而写的工具类，你可以直接用Toast的语法修改回来就可以了。}});} catch (IOException e) {Toasts.showShort(MainViewActivity.this,"查询失败,文件读写异常");}catch (Exception e) {Toasts.showShort(MainViewActivity.this,"查询失败，其他异常");}

服务器发送给客户端的数据的数据封装类ResponseContent（具体业务的一部分，可以根据实际需求修改）：

package com.szhushou.ssp.model;public class ResponseContent{private String name;private String metter;public void setName(String name) {this.name = name;}public void setMetter(String metter) {this.metter = metter;}public String getName() {return name;}public String getMetter() {return metter;}}

客户端的代码就介绍完了，接下来就是服务器端的了

服务器端：
服务器端程序入口类ServerMain（主要用来接收客户端的连接信息，把信息传递给线程处理）：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;import com.szhushou.ssps.util.SystemMethod;public class ServerMain
{private static final String TAG = "ServerMain";public static void main(String args[]) {ServerSocket server;try {server = new ServerSocket(FinalValue.host);Socket client;while(true){client=server.accept();new SportThread(client).start();}} catch (IOException e) {System.out.println(TAG+" main "+e.getMessage());}}
}

服务器端事件处理线程SportThread（主要用来处理或者分发处理业务逻辑，这是修改的重点）：

package com.szhushou.ssps;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.szhushou.ssps.factory.FindImage;
import com.szhushou.ssps.factory.Login;
import com.szhushou.ssps.factory.MyFactory;
import com.szhushou.ssps.model.client.RequestMessage;
import com.szhushou.ssps.model.server.ResultMessage;
import com.szhushou.ssps.util.BeanList;
import com.szhushou.ssps.util.SpringFactory;
import com.szhushou.ssps.util.SystemMethod;public class SportThread extends Thread {private static final String TAG = "PublicMethod";private final static String END = "#end#";// 用来结束发送的字符串Socket client;public SportThread(Socket client) {this.client = client;//}public void run() {try {BufferedReader ois = new BufferedReader(new InputStreamReader(client.getInputStream()));PrintStream oos = new PrintStream(client.getOutputStream());String requestData = readString(ois);RequestMessage messageIn = JSON.parseObject(requestData,RequestMessage.class);ResultMessage messageOut = EventDispose(messageIn);String resultData = JSONObject.toJSONString(messageOut);sendString(oos, resultData);ois.close();oos.close();if (!client.isClosed()) {client.close();}} catch (IOException e) {System.out.println(TAG+" run "+e.getMessage());}}private String readString(BufferedReader ois) throws IOException {String result;String bufferText;StringBuffer resultBuffer = new StringBuffer();while (!(bufferText = ois.readLine()).equals(END)) {resultBuffer.append(bufferText);}result = resultBuffer.toString();return result;}private void sendString(PrintStream out, String text) {out.println(text);out.println(END);out.flush();}public ResultMessage EventDispose(RequestMessage messageIn)throws IOException {ResultMessage messageOut = new ResultMessage();int type = messageIn.getCode();MyFactory factory = null;try {switch (type) {case 1:Map<String, String> map=messageIn.getData();String name=map.get("name");String metter=map.get("metter");//TODO处理消息...ResponseMetter responseMetter=new ResponseMetter();responseMetter.setMetter("already get message");responseMetter.setName("server");messageOut=new ResultMessage(false,responseMetter);break;default:break;}} catch (Exception e) {System.out.println(TAG+" EventDispose "+ e.getMessage());messageOut=new ResultMessage(false,null);}return messageOut;}
}

服务器端的接收消息模板类RequestMessage（主要是用来封装接收的信息的，慎改）：

package com.szhushou.ssps.model.client;import java.util.Map;public class RequestMessage
{private Integer code;private Map<String, String> data;public void setCode(Integer code) {this.code = code;}public void setData(Map<String, String> data) {this.data = data;}public Integer getCode() {return code;}public Map<String, String> getData() {return data;}
}

服务器端的返回结果模板类ResultMessage（主要用来封装发送给客户端的信息的，慎改）：

package com.szhushou.ssps.model.server;public class ResultMessage {private boolean ok;private Object data;public ResultMessage(){}public ResultMessage(boolean ok,Object data){this.ok=ok;this.data=data;}public void setOk(boolean ok) {this.ok = ok;}public void setData(Object data) {this.data = data;}public boolean isOk() {return ok;}public Object getData() {return data;}
}

服务器端的消息封装类ResponseMetter（该类是用来封装具体信息的，内容和客户端的ResponseContent对应，可以根据业务修改和新建）：

package com.szhushou.ssps.model.server;public class ResponseMetter{private String name;private String metter;public void setName(String name) {this.name = name;}public void setMetter(String metter) {this.metter = metter;}public String getName() {return name;}public String getMetter() {return metter;}}

提示：
本次代码的JSON部分主要使用带了阿里的开源代码FastJson，下载地址为：https://github.com/alibaba/fastjson/releases

总结:
经历了一上午，终于把博客写完了，如果有什么地方没考虑到部分，还望多多指教。后续有时间再继续跟进。

android利用socket与java后台交互的设计与实现相关推荐

如何用CropBox实现头像裁剪并与java后台交互
如何用CropBox实现头像裁剪并与java后台交互参考网站:https://developer.mozilla.org/zh-CN/docs/Web/API/Blob 参考: http://blo ...
winsock使用java编写_利用Socket进行Java网络编程（一）
利用Socket进行Java网络编程(一) 考试吧(Exam8.com) 2003-03-04 08:00:00 评论(0)条作者: 郗旻 Socket是网络上运行的两个程序间双向通讯的一端,它既可 ...
Android利用Socket与硬件通信之智能家居APP
Android利用Socket与硬件通信之智能家居APP - JCLovebiancheng - 博客园在socket使用时,可以用1024-65535的端口号
java 企业信息门户拖拽排版_web中拖拽排序与java后台交互实现
一.业务需求 1,在后台的管理界面通过排序功能直接进入排序界面 2,在排序界面能够人工的手动拖动需要排序的标题,完成对应的排序之后提交 3,在app或者是前端就有对应的排序实现了二.页面展示将整体 ...
android数据存放map_android - Java后台把数据用json发到手机端，里面是map存放的，必须要说明数据的类型？...
问题 List reList = new ArrayList(); for(int i=0;i Zqwl_yd_jdxx bjd = bjdList.get(i); HashMap temp = n ...
利用socket实现java程序自动关闭
今天发现一段有意思的程序,记录下来,娱乐自己. 1.实运行main方法时传两个参数 '应用命令'和'socket端口' 步骤1.启动java程序,参数(start 80890),启动serverS ...
前端框架ice飞冰与java后台交互分享
飞冰开发环境配置 node.js 安装 https://alibaba.github.io/ice/docs/basis/env-config Iceworks 快速开始文档 https://alib ...
关于微信小程序与Java后台交互数据中中文乱码问题的讨论
小程序端请求参数中含有中文如果小程序端发起的请求参数中含有中文,直接发送到后台会显示乱码,需要在header中设置UTF-8编码 wx.request({url: app.globalData.se ...
Android 客户端Socket 与 Java服务端ServerSocket
Socket编程一.Java网络编程基础知识 1.两台计算机间进行通讯需要以下三个条件: 1). IP地址(例如 : 192.168.1.1) 2). 协议(服务端与客户端之间双方自行 ...
入门：HTML表单与Java 后台交互(复选框提交)
仅仅给出部分关键代码: HTML form code: <form action="JavaFormTest" method="post" name=&q ...

android利用socket与java后台交互的设计与实现

android利用socket与java后台交互的设计与实现相关推荐

最新文章

热门文章