Android学习笔记三十五：socket编程实现消息推送

出处&＃xff1a;http://m.blog.csdn.net/article/details?id&＃61;41924151

上篇文章Android socket 编程 实现消息推送&＃xff08;一&＃xff09;讲到socket编程的消息推送原理&＃xff0c;现在我们来看看基于Android客户机socket编程实现消息推送的过程。

根据消息推送的原理图&＃xff0c;我们的实现过程主要分为Server端和Client端&＃xff0c;Server端采用Java的编程&＃xff0c;而Client端则用Android编程。

所以在这里也分别创建了两个工程SocketServer和SocketClient

1.SocketServer工程

我们先来看一下SocketMessage.java类&＃xff1a;

public class SocketMessage {public int to;//socketID&＃xff0c;指发送给谁public int from;//socketID&＃xff0c;指谁发送过来的public String msg;//消息内容public String time;//接收时间public SocketThread thread;//socketThread下面有介绍
}

该类是一个消息类&＃xff0c;用于表示消息是由谁发给谁的、消息内容是什么、接收时间是多少&＃xff0c;只有几个属性&＃xff0c;比较简单。

而MyServer.java类就相对比较多一些代码&＃xff1a;

package com.jimstin.server;import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;import org.json.JSONObject;import com.jimstin.msg.SocketMessage;public class MyServer {private boolean isStartServer;private ServerSocket mServer;/*** 消息队列&＃xff0c;用于保存SocketServer接收来自于客户机&＃xff08;手机端&＃xff09;的消息*/private ArrayList mMsgList &＃61; new ArrayList();/*** 线程队列&＃xff0c;用于接收消息。每个客户机拥有一个线程&＃xff0c;每个线程只接收发送给自己的消息*/private ArrayList mThreadList &＃61; new ArrayList();/*** 开启SocketServer*/private void startSocket() {try {isStartServer &＃61; true;int prot &＃61; 2000;//端口可以自己设置&＃xff0c;但要和Client端的端口保持一致mServer &＃61; new ServerSocket(prot);//创建一个ServerSocketSystem.out.println("启动server,端口&＃xff1a;"&＃43;prot);Socket socket &＃61; null;int socketID &＃61; 0;//Android&＃xff08;SocketClient&＃xff09;客户机的唯一标志&＃xff0c;每个socketID表示一个Android客户机//开启发送消息线程startSendMessageThread();//用一个循环来检测是否有新的客户机加入while(isStartServer) {//accept()方法是一个阻塞的方法&＃xff0c;调用该方法后&＃xff0c;//该线程会一直阻塞&＃xff0c;直到有新的客户机加入&＃xff0c;代码才会继续往下走socket &＃61; mServer.accept();//有新的客户机加入后&＃xff0c;则创建一个新的SocketThread线程对象SocketThread thread &＃61; new SocketThread(socket, socketID&＃43;&＃43;);thread.start();//将该线程添加到线程队列mThreadList.add(thread);}} catch (Exception e) {e.printStackTrace();}}/*** 开启推送消息线程&＃xff0c;如果mMsgList中有SocketMessage&＃xff0c;则把该消息推送到Android客户机*/public void startSendMessageThread() {new Thread(){&＃64;Overridepublic void run() {super.run();try {/*如果isStartServer&＃61;true&＃xff0c;则说明SocketServer已启动&＃xff0c;用一个循环来检测消息队列中是否有消息&＃xff0c;如果有&＃xff0c;则推送消息到相应的客户机*/while(isStartServer) {//判断消息队列中的长度是否大于0&＃xff0c;大于0则说明消息队列不为空if(mMsgList.size() > 0) {//读取消息队列中的第一个消息SocketMessage from &＃61; mMsgList.get(0);for(SocketThread to : mThreadList) {if(to.socketID &＃61;&＃61; from.to) {BufferedWriter writer &＃61; to.writer;JSONObject json &＃61; new JSONObject();json.put("from", from.from);json.put("msg", from.msg);json.put("time", from.time);//writer写进json中的字符串数据&＃xff0c;末尾记得加换行符&＃xff1a;"\n"&＃xff0c;否则在客户机端无法识别//因为BufferedReader.readLine()方法是根据换行符来读取一行的writer.write(json.toString()&＃43;"\n");//调用flush()方法&＃xff0c;刷新流缓冲&＃xff0c;把消息推送到手机端writer.flush();System.out.println("推送消息成功&＃xff1a;"&＃43;from.msg&＃43;">> to socketID:"&＃43;from.to);break;}}//每推送一条消息之后&＃xff0c;就要在消息队列中移除该消息mMsgList.remove(0);}Thread.sleep(200);}} catch (Exception e) {e.printStackTrace();}}}.start();}/*** 定义一个SocketThread类&＃xff0c;用于接收消息**/public class SocketThread extends Thread {public int socketID;public Socket socket;//Socket用于获取输入流、输出流public BufferedWriter writer;//BufferedWriter 用于推送消息public BufferedReader reader;//BufferedReader 用于接收消息public SocketThread(Socket socket, int count) {socketID &＃61; count;this.socket &＃61; socket;System.out.println("新增一台客户机&＃xff0c;socketID&＃xff1a;"&＃43;socketID);}&＃64;Overridepublic void run() {super.run();try {//初始化BufferedReaderreader &＃61; new BufferedReader(new InputStreamReader(socket.getInputStream(), "utf-8"));//初始化BufferedWriterwriter &＃61; new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "utf-8"));//如果isStartServer&＃61;true&＃xff0c;则说明SocketServer已经启动&＃xff0c;//现在需要用一个循环来不断接收来自客户机的消息&＃xff0c;并作其他处理while(isStartServer) {//先判断reader是否已经准备好if(reader.ready()) {/*读取一行字符串&＃xff0c;读取的内容来自于客户机reader.readLine()方法是一个阻塞方法&＃xff0c;从调用这个方法开始&＃xff0c;该线程会一直处于阻塞状态&＃xff0c;直到接收到新的消息&＃xff0c;代码才会往下走*/String data &＃61; reader.readLine();//讲data作为json对象的内容&＃xff0c;创建一个json对象JSONObject json &＃61; new JSONObject(data);//创建一个SocketMessage对象&＃xff0c;用于接收json中的数据SocketMessage msg &＃61; new SocketMessage();msg.to &＃61; json.getInt("to");msg.msg &＃61; json.getString("msg");msg.from &＃61; socketID;msg.time &＃61; getTime(System.currentTimeMillis());//接收到一条消息后&＃xff0c;将该消息添加到消息队列mMsgListmMsgList.add(msg);System.out.println("收到一条消息&＃xff1a;"&＃43;json.getString("msg")&＃43;" >>>> to socketID:"&＃43;json.getInt("to"));}//睡眠100ms&＃xff0c;每100ms检测一次是否有接收到消息Thread.sleep(100);}} catch (Exception e) {e.printStackTrace();} }}/*** 获取指定格式的时间字符串&＃xff0c;通过毫秒转换日期* &＃64;param millTime*/private String getTime(long millTime) {Date d &＃61; new Date(millTime);SimpleDateFormat sdf &＃61; new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");return sdf.format(d);}public static void main(String[] args) {MyServer server &＃61; new MyServer();server.startSocket();}}

2.SocketClient工程

该工程是一个Android的工程&＃xff0c;只有一个MainActivity.java和activity_main.xml文件&＃xff0c;

先看一下activity_main.xml布局文件&＃xff1a;






效果图&＃xff1a;

MainActivity.java类&＃xff1a;

package com.jimstin.socketclient;import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.Date;import org.json.JSONObject;import com.tencent.stat.MtaSDkException;
import com.tencent.stat.StatConfig;
import com.tencent.stat.StatService;import android.R.integer;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
import android.app.Activity;public class MainActivity extends Activity implements OnClickListener {private EditText mIPEdt, mPortEdt, mSocketIDEdt, mMessageEdt;private static TextView mConsoleTxt;private static StringBuffer mConsoleStr &＃61; new StringBuffer();private Socket mSocket;private boolean isStartRecieveMsg;private SocketHandler mHandler;protected BufferedReader mReader;//BufferedWriter 用于推送消息protected BufferedWriter mWriter;//BufferedReader 用于接收消息&＃64;Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);initView();}private void initView() {mIPEdt &＃61; (EditText) findViewById(R.id.ip_edt);mPortEdt &＃61; (EditText) findViewById(R.id.port_edt);mSocketIDEdt &＃61; (EditText) findViewById(R.id.socket_id_edt);mMessageEdt &＃61; (EditText) findViewById(R.id.msg_edt);mConsoleTxt &＃61; (TextView) findViewById(R.id.console_txt);findViewById(R.id.start_btn).setOnClickListener(this);findViewById(R.id.send_btn).setOnClickListener(this);findViewById(R.id.clear_btn).setOnClickListener(this);mHandler &＃61; new SocketHandler();}/*** 初始化socket*/private void initSocket() {//新建一个线程&＃xff0c;用于初始化socket和检测是否有接收到新的消息Thread thread &＃61; new Thread(new Runnable() {&＃64;Overridepublic void run() {String ip &＃61; mIPEdt.getText().toString();//IPint port &＃61; Integer.parseInt(mPortEdt.getText().toString());//Sockettry {isStartRecieveMsg &＃61; true;mSocket &＃61; new Socket(ip, port);mReader &＃61; new BufferedReader(new InputStreamReader(mSocket.getInputStream(), "utf-8"));mWriter &＃61; new BufferedWriter(new OutputStreamWriter(mSocket.getOutputStream(), "utf-8"));while(isStartRecieveMsg) {if(mReader.ready()) {/*读取一行字符串&＃xff0c;读取的内容来自于客户机reader.readLine()方法是一个阻塞方法&＃xff0c;从调用这个方法开始&＃xff0c;该线程会一直处于阻塞状态&＃xff0c;直到接收到新的消息&＃xff0c;代码才会往下走*/String data &＃61; mReader.readLine();//handler发送消息&＃xff0c;在handleMessage()方法中接收mHandler.obtainMessage(0, data).sendToTarget();}Thread.sleep(200);}mWriter.close();mReader.close();mSocket.close();} catch (Exception e) {e.printStackTrace();} }});thread.start();}&＃64;Overridepublic void onClick(View v) {switch (v.getId()) {case R.id.send_btn:send();break;case R.id.clear_btn:mConsoleStr.delete(0, mConsoleStr.length());mConsoleTxt.setText(mConsoleStr.toString());break;case R.id.start_btn:if(!isStartRecieveMsg) {initSocket();}break;default:break;}}/*** 发送*/private void send() {new AsyncTask() {&＃64;Overrideprotected String doInBackground(String... params) {sendMsg();return null;}}.execute();}/*** 发送消息*/protected void sendMsg() {try {String socketID &＃61; mSocketIDEdt.getText().toString().trim();String msg &＃61; mMessageEdt.getText().toString().trim();JSONObject json &＃61; new JSONObject();json.put("to", socketID);json.put("msg", msg);mWriter.write(json.toString()&＃43;"\n");mWriter.flush();mConsoleStr.append("我:" &＃43;msg&＃43;" "&＃43;getTime(System.currentTimeMillis())&＃43;"\n");mConsoleTxt.setText(mConsoleStr);} catch (Exception e) {e.printStackTrace();}}static class SocketHandler extends Handler {&＃64;Overridepublic void handleMessage(Message msg) {// TODO Auto-generated method stubsuper.handleMessage(msg);switch (msg.what) {case 0:try {//将handler中发送过来的消息创建json对象JSONObject json &＃61; new JSONObject((String)msg.obj);mConsoleStr.append(json.getString("from")&＃43;":" &＃43;json.getString("msg")&＃43;" "&＃43;getTime(System.currentTimeMillis())&＃43;"\n");//将json数据显示在TextView中mConsoleTxt.setText(mConsoleStr);} catch (Exception e) {e.printStackTrace();}break;default:break;}}}&＃64;Overridepublic void onBackPressed() {super.onBackPressed();isStartRecieveMsg &＃61; false;}private static String getTime(long millTime) {Date d &＃61; new Date(millTime);SimpleDateFormat sdf &＃61; new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");return sdf.format(d);}}



以上代码的注释都比较详细&＃xff0c;就不再多说了。

资源下载地址&＃xff1a;http://download.csdn.net/detail/zhangjm_123/8258019

注意&＃xff1a;先把Android端的apk分别安装到两台手机上面&＃xff0c;再运行SocketServer&＃xff0c;点击SocketClient的Start&＃xff0c;在SocketServer的控制台上面就可以看到有新的客户机增加了&＃xff08;确保IP地址和端口的正确前提下&＃xff09;。然后输入socketID&＃xff08;socketID表示Android客户机的一个账号&＃xff0c;就像QQ号一样&＃xff0c;从0开始&＃xff0c;一个socketID表示一个客户机&＃xff09;和content&＃xff0c;点击send就可以发送消息了。

效果图请见Android socket 编程 实现消息推送&＃xff08;一&＃xff09;