上一次我们讲了app的基本控件的监听和初始化的过程,这次我们就把上次提到的socket通讯进行更细的讲解。
发送消息
发送消息是我们的一个基本执行操作,下面就是我们发送消息的代码
private void sendMessage(String msg)
{
output.print(msg);
}```
##心跳
对于远程服务器,有一个心跳机制,**心跳检测 **是能够提高系统可用性的措施。
例如:服务端和客户端之间进行通讯,每隔5分钟进行一次心跳检测,检测和主站连接是否正常。客户端每5分钟发一个心跳检测数据帧,服务端接收到数据帧表示通过,否则表示客户端断开,抛出异常。
判断对方(设备,进程或其它网元)是否正常动行,一般采用定时发送简单的通讯包,如果在指定时间段内未收到对方响应,则判断对方已经当掉。用于检测TCP的异常断开。基本原因是服务器端不能有效的判断客户端是否在线也就是说,服务器无法区分客户端是长时间在空闲,还是已经掉线的情况。所谓的心跳包就是客户端定时发送简单的信息给服务器端告诉它我还在而已。
所以,我们需要一个task来执行我们心跳的操作以保证手机与服务器的稳定连接。
public class SendLogTask extends AsyncTask<Void,Void,String>
{
private final Timer timer =new Timer();
private TimerTask task;
@Override
protected String doInBackground(Void...param){
task=new TimerTask(){
@Override
public void run(){
sendMessage("(ping)"+"\r\n");
}
};
timer.schedule(task, 50000, 50000);
return "";
}}```
接收信息
我们发数据去到下位机,当然也需要下位机的信息反馈,比如操作成功了没,硬件的状态怎么样等。因此,我们还需要一个实时接收信息的task。
public class GetLogTask extends AsyncTask<Void,Void,String>
{
@Override
protected String doInBackground(Void...param){
try {
InputStream inputStream = socket.getInputStream();
DataInputStream input = new DataInputStream(inputStream);
byte[] b = new byte[10000];
while(true)
{
int length = input.read(b);
String Msg = new String(b, 0, length, "gb2312");
Message msg=new Message();
msg.obj = Msg;
(MainActivity.this).handler.sendMessage(msg);
Log.v("data",Msg);
}
}catch(Exception ex)
{
ex.printStackTrace();
}
return "";
}
}
Handler handler = new Handler(){
@Override
public void handleMessage(Message msg){
state.setText((String)msg.obj);
}
};```
##关于AsyncTask
在一开始的时候,我使用的thread线程通讯的形式,但是当我把两个thread同时执行时,我发现在手机上的app反馈的是执行时间十分长,就是操作卡顿,我对此十分不解,这也是我对android线程机制了解不够透彻的原因。后来,我通过查找资料才知道AsyncTask这种东西。
在开发Android移动客户端的时候往往要使用多线程来进行操作,我们通常会将耗时的操作放在单独的线程执行,避免其占用主线程而给用户带来不好的用户体验。但是在子线程中无法去操作主线程(UI 线程),在子线程中操作UI线程会出现错误。因此android提供了一个类Handler来在子线程中来更新UI线程,用发消息的机制更新UI界面,呈现给用户。这样就解决了子线程更新UI的问题。但是费时的任务操作总会启动一些匿名的子线程,太多的子线程给系统带来巨大的负担,随之带来一些性能问题。
因此android提供了一个工具类AsyncTask,顾名思义异步执行任务。这个AsyncTask生来就是处理一些后台的比较耗时的任务,给用户带来良好用户体验的,不再需要子线程和Handler就可以完成异步操作并且刷新用户界面。
所以,当我们需要不停地发送和接收消息时,AsyncTask是我们的不二选择。