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

缺乏、安全感 2022-07-24 10:16 335阅读 0赞

出处：[http://m.blog.csdn.net/article/details?id=41924151][http_m.blog.csdn.net_article_details_id_41924151]

上篇文章[Android socket 编程 实现消息推送（一）][Android socket _]讲到socket编程的消息推送原理，现在我们来看看基于Android客户机socket编程实现消息推送的过程。

![Center][]

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

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

1.SocketServer工程

![20141214122319433][]

我们先来看一下SocketMessage.java类：

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

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

而MyServer.java类就相对比较多一些代码：

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

2.SocketClient工程

![20141214122344814][]

该工程是一个Android的工程，只有一个MainActivity.java和activity\_main.xml文件，

先看一下activity\_main.xml布局文件：

效果图：

![20141214134014171][]

MainActivity.java类：

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 = new StringBuffer();
    	private Socket mSocket;
    	private boolean isStartRecieveMsg;
    	
    	private SocketHandler mHandler;
    	protected BufferedReader mReader;//BufferedWriter 用于推送消息
    	protected BufferedWriter mWriter;//BufferedReader 用于接收消息
    	
        @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.activity_main);
            initView();
        }
    
    	private void initView() {
    		mIPEdt = (EditText) findViewById(R.id.ip_edt);
    		mPortEdt = (EditText) findViewById(R.id.port_edt);
    		mSocketIDEdt = (EditText) findViewById(R.id.socket_id_edt);
    		mMessageEdt = (EditText) findViewById(R.id.msg_edt);
    		mConsoleTxt = (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 = new SocketHandler();
    	}
    
    	/**
    	 * 初始化socket
    	 */
    	private void initSocket() {
    		//新建一个线程，用于初始化socket和检测是否有接收到新的消息
    		Thread thread = new Thread(new Runnable() {
    			
    			@Override
    			public void run() {
    				String ip = mIPEdt.getText().toString();//IP
    				int port = Integer.parseInt(mPortEdt.getText().toString());//Socket
    				
    				try {
    					isStartRecieveMsg = true;
    					mSocket = new Socket(ip, port);
    					mReader = new BufferedReader(new InputStreamReader(mSocket.getInputStream(), "utf-8"));
    					mWriter = new BufferedWriter(new OutputStreamWriter(mSocket.getOutputStream(), "utf-8"));
    					while(isStartRecieveMsg) {
    						if(mReader.ready()) {
    							/*读取一行字符串，读取的内容来自于客户机
    							reader.readLine()方法是一个阻塞方法，
    							从调用这个方法开始，该线程会一直处于阻塞状态，
    							直到接收到新的消息，代码才会往下走*/
    							String data = mReader.readLine();
    							//handler发送消息，在handleMessage()方法中接收
    					        mHandler.obtainMessage(0, data).sendToTarget();
    						}
    						Thread.sleep(200);
    					}
    					mWriter.close();
    					mReader.close();
    					mSocket.close();
    				} catch (Exception e) {
    					e.printStackTrace();
    				} 
    			}
    		});
    		thread.start();
    	}
    	
    	@Override
    	public 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<String, Integer, String>() {
    
    			@Override
    			protected String doInBackground(String... params) {
    				sendMsg();
    				return null;
    			}
    		}.execute();
    	}
    	/**
    	 * 发送消息
    	 */
    	protected void sendMsg() {
    		try {
    			String socketID = mSocketIDEdt.getText().toString().trim();
    			String msg = mMessageEdt.getText().toString().trim();
    			JSONObject json = new JSONObject();
    			json.put("to", socketID);
    			json.put("msg", msg);
    			mWriter.write(json.toString()+"\n");
    			mWriter.flush();
    			mConsoleStr.append("我:" +msg+"   "+getTime(System.currentTimeMillis())+"\n");
    			mConsoleTxt.setText(mConsoleStr);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    	static class SocketHandler extends Handler {
    		
    		@Override
    		public void handleMessage(Message msg) {
    			// TODO Auto-generated method stub
    			super.handleMessage(msg);
    			switch (msg.what) {
    			case 0:
    				try {
    					//将handler中发送过来的消息创建json对象
    					JSONObject json = new JSONObject((String)msg.obj);
    					mConsoleStr.append(json.getString("from")+":" +json.getString("msg")+"   "+getTime(System.currentTimeMillis())+"\n");
    					//将json数据显示在TextView中
    					mConsoleTxt.setText(mConsoleStr);
    				} catch (Exception e) {
    					e.printStackTrace();
    				}
    				
    				break;
    
    			default:
    				break;
    			}
    		}
    	}
    	
    	@Override
    	public void onBackPressed() {
    		super.onBackPressed();
    		isStartRecieveMsg = false;
    	}
    	
    	private static String getTime(long millTime) {
    		Date d = new Date(millTime);
    		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    		return sdf.format(d);
    	}
    	
    }

以上代码的注释都比较详细，就不再多说了。

资源下载地址：http://download.csdn.net/detail/zhangjm\_123/8258019

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

效果图请见[Android socket 编程 实现消息推送（一）][Android socket _]

[http_m.blog.csdn.net_article_details_id_41924151]: http://m.blog.csdn.net/article/details?id=41924151
[Android socket _]: http://blog.csdn.net/zhangjm_123/article/details/41512833
[Center]: /images/20220722/de943c3e0bc94f2c9aec95f1b0a29761.png
[20141214122319433]: /images/20220722/7437af362ffd4716b186e9c5eefae348.png
[20141214122344814]: /images/20220722/7ae610f8846646bb87610e3695a6fcdc.png
[20141214134014171]: /images/20220722/91adcd1f20db4100833a89e91a655010.png