服务端：mysql+hibernate；
客户端：android
最近自己在做聊天软件的时候要在服务端和客户端之间进行数据传递，开始得时候使用socket，后来发现使用socket有点局限性，所以改用了http的方式，摸索了两天，终于连通了服务端和客户端
思路：
1.服务端提供接收数据的servlet
2.客户端将需要发送的数据转换成json格式
3.客户端启动线程，将json数据放入request请求中，通过httpclient发送至服务端
4.服务端通过request拿到输入流，解析为json数据
5.服务端进行业务逻辑处理（若无需进行进行业务逻辑处理，此步骤可省略）
6.将需要返回的数据或业务逻辑处理结果转换成json格式，通过response的流将json数据输出给客户端
7.客户端通过response获取流，解析成json数据
8.若需要更新UI，则通过handler将数据发送回主线程，更新UI
服务端代码：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
package com.durian.fc.server.servlet;
import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.durian.fc.server.entity.User;
import com.durian.fc.server.service.UserManager;
import net.sf.json.JSONObject;
public class RegisterServlet extends HttpServlet {
private static final long serialVersionUID = 541282327938079229L;
private UserManager manager = new UserManager();
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
doPost(req, resp);
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
StringBuilder sb = new StringBuilder();
String s = null;
BufferedReader br = new BufferedReader(new InputStreamReader(req.getInputStream()));
while((s=br.readLine())!=null){
sb.append(s);
}
JSONObject jo= JSONObject.fromObject(sb.toString());
String password = jo.getString("password");
String phone = jo.getString("phone");
System.out.println(s);
Boolean b = false;
b = manager.saveUser(password,phone);
jo.clear();
jo.put("isExit", b);
PrintWriter pw = resp.getWriter();
pw.write(jo.toString());
}
}
|
客户端工具类代码：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 |
package com.durian.fc.client.utils;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.params.CoreConnectionPNames;
import org.json.JSONObject;
import android.util.Log;
public class HttpUtils {
public final static int METHOD_GET = 1;
public final static int METHOD_POST = 2;
public static HttpEntity getHttpEntity(String uri,int method,JSONObject json){
HttpEntity entity = null;
HttpClient client = new DefaultHttpClient();
client.getParams().setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 10000);
client.getParams().setParameter(CoreConnectionPNames.SO_TIMEOUT,10000);
HttpUriRequest req = null;
switch (method) {
case METHOD_GET:
req = new HttpGet(uri);
break;
case METHOD_POST:
try {
Log.i("info", "post started");
req = new HttpPost(uri);
((HttpPost)req).setEntity(new StringEntity(json.toString()));
} catch (UnsupportedEncodingException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
break;
}
try {
HttpResponse res = client.execute(req);
if(res.getStatusLine().getStatusCode() == HttpStatus.SC_OK){
return entity = res.getEntity();
}
} catch (ClientProtocolException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return entity;
}
public static InputStream getInputStream(HttpEntity entity){
InputStream in = null;
try {
if(entity!= null){
return in = entity.getContent();
}
} catch (IllegalStateException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return in;
}
|
客户端代码
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 |
jo.put("password", pass1);
new Thread(new Runnable() {
public void run() {
HttpEntity entity = HttpUtils.getHttpEntity("http://192.168.1.105:8080/FCS2/registerServlet", 2, jo);
InputStream in = HttpUtils.getInputStream(entity);
if(in!=null){
try {
BufferedReader br = new BufferedReader(new InputStreamReader(in));
StringBuilder sb = new StringBuilder();
String s = null;
while((s=br.readLine())!=null){
sb.append(s);
}
JSONObject jo2 = new JSONObject(sb.toString());
System.out.println(jo2.getBoolean("isExit"));
Message msg = Message.obtain(handler, 1, jo2.getBoolean("isExit"));
msg.sendToTarget();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}).start();
|