网络对讲机C#服务器 Android客户端（三） android客户端代码分析

完整的工程下载地址（源码）：http://download.csdn.net/detail/zhujinghao09/5313666

因为这个版本只是功能实现的测试版，所以界面做的很丑，请大家见谅，主要看功能哦！！

主要功能：

连接服务器，并开启一个监听来信的线程，如果有来信，开启接收文件线程；

按钮控制发送语音线程；

使用第三方类实现原生未压缩的录音格式 .wav；

使用android 系统自带的mediaPlayer 实现声音播放功能；

第一步：连接服务器

btnConnect.setOnClickListener(newButton.OnClickListener()

{

@Override

publicvoid onClick(View arg0) {

//TODO Auto-generated method stub

//IP=etIp.getContext().toString();

IP= etIp.getText().toString();

try{

Port= Integer.parseInt(etPort.getText().toString());

}catch(Exceptione)

{

Log.i(Tag,"IP"+IP+"port"+Port);

Toast.makeText(MainActivity.this,"请输入正确的端口号！！",Toast.LENGTH_LONG).show();

return;

}

try{

client= new Socket(IP, Port); //连接服务器

}catch (UnknownHostException e) {

//TODO Auto-generated catch block

e.printStackTrace();

Toast.makeText(MainActivity.this,"UnknownHostException", Toast.LENGTH_LONG).show();

return;

}catch (IOException e) {

//TODO Auto-generated catch block

e.printStackTrace();

Toast.makeText(MainActivity.this,"IOException！",Toast.LENGTH_LONG).show();

return;

}

PrintWriterout;

try{

out= new PrintWriter(client.getOutputStream(), true);

out.println("Android"); //向服务器发送客户端名称

}catch (IOException e) {

//TODO Auto-generated catch block

e.printStackTrace();

}

tvState.setText("连接服务器成功！！！");

SocketListensListen = new SocketListen(client,mHandler); //开启监听接收线程

sListen.SetControlBar(tvRecvCount);

sListen.start();

}

});

第二步：监听接收线程

package er.fly;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;

import er.fly.nettandclient.MyHandler;

import android.util.Log;
import android.widget.TextView;

public class SocketListen extends Thread{

	 private Socket client; 
	 //private String savepath="/sdcard/MyVoice/";
	 MyHandler mHandler;
	 MyHandler SLHandler;
	 TextView tvR;
	 public SocketListen(Socket s,MyHandler h)
	 {
		 this.client=s;
		 mHandler = h;
	 }
	 public void SetControlBar(TextView tv)
	 {
		 tvR = tv;
	 }
	 public void run() 
	 {  
		 int len;
	        if (client == null)  
	            return;  
	        while(true)                   //循环监听来信
	        {
	        	BufferedReader in;// = new BufferedReader(new InputStreamReader(System.in));
				// 接收来自 server 的响应数据
							try {
								in = new BufferedReader(new InputStreamReader(client
										.getInputStream()));
								try
								{
										String strlen= in.readLine();   //读取网络流，文件长度
										//System.out.println("File Size :"+strlen);
										Log.i("SocketListen", strlen);
										len = Integer.parseInt(strlen);
										//开启接收文件线程
                                                                                DownloadFile downFile = new DownloadFile(client,len);
                                                                                downFile.SetHanglers(mHandler, SLHandler);
										downFile.SetControlBar(tvR);
										downFile.start();
										//this.suspend();
										while(true)    //判断文件是否接收完成//等待  
										{
											if(!downFile.isAlive())
											break;
										}
								}catch(IOException e)
								{
									Log.i("SocketListen", "no recv");
								}
								
								
								
								
							} catch (IOException e) {
								// TODO Auto-generated catch block
								
								//e.printStackTrace();
							}	 
	        }
	 
	 }
}

接收文件线程类：

package er.fly;

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Date;

import er.fly.nettandclient.MyHandler;

import android.os.Looper;
import android.os.Message;
import android.util.Log;
import android.widget.TextView;
//import er.fly.nettandclient;
public class DownloadFile extends Thread{

	private Socket client;
    File file=null;  
    String sendinfo=null; 
    int fileLen;
    String tag = "DownloadFile"; 
    MyHandler mHandler;                            //用于子线程和主线程通信，更新声音列表
    MyHandler SLHandler;
    TextView tvRecvCount;
    String recvVoiceSavePath;
    public DownloadFile(Socket s,int l)
	{
		 this.client = s;
		 fileLen=l;
	}
    public void SetHanglers(MyHandler m,MyHandler sl)
    {
    	mHandler = m;
    	SLHandler = sl;
    }
    public void SetControlBar(TextView tv)
	 {
		 tvRecvCount = tv;
	 }
    // 创建目录（不存在则创建）  
    public File CreateDir(String dir) {  
        File file = new File(dir);  
        if (!file.exists()) {  
            file.mkdirs();  
        }  
        return file;  
    }  
    public void run()
    {
    	Looper curLooper = Looper.myLooper();
    	Looper mainLooper = Looper.getMainLooper();
    	String msg=null;
    	boolean flag = false;
    	if(client == null)
    	{
    		return ;
    	}
    	try
    	{
    		
			InputStream inputStream = client.getInputStream();
			
			byte[] buffer = new byte[1024];
	    	int readCount = 0;
	    	int count=0;
	    	CreateDir("sdcard/MyRecvVoice/");
	    	int h = new Date().getHours();
			int m = new Date().getMinutes();
			int s = new Date().getSeconds();
			String strTime = String.valueOf(h)+"-"+String.valueOf(m)+"-"+String.valueOf(s);
	    	BufferedOutputStream fo = new BufferedOutputStream(new FileOutputStream(new File("sdcard/MyRecvVoice/"+strTime+".wav")));
	    	//循环接收文件
	    	while (true) 
	    	{ 
	    		readCount = inputStream.read(buffer);
	    		count = count+readCount;
	    		fo.write(buffer, 0,readCount);
	    		//System.out.println("recv len " + String.valueOf(count)+"readCount "+String.valueOf(readCount));
	    		Log.i(tag, "recv len"+ String.valueOf(count)+"readCount "+String.valueOf(readCount));
	    		if(count>=fileLen)  //判断接收结束
		    		break;
	    	}
	    	
	    	flag = true;
	    	recvVoiceSavePath="sdcard/MyRecvVoice/"+strTime+".wav";
	    	Log.i(tag,"接收成功！！");  
	    	fo.flush();
	    	fo.close();
	    	//inputStream.close();//   一定不能关闭输入输出流，因为关闭它们的同时也会关闭socket    //这个很重要
	    	//outputStream.close();
    	}
    	catch(IOException e)
    	{
    		e.printStackTrace();
    	}
    	
    	mHandler = new MyHandler(mainLooper);
    	mHandler.SetHandlerArgs(tvRecvCount);
    	if(flag)
    		msg="DownloadFile:"+recvVoiceSavePath+"#"+"接收成功！！"; 
    	else
    		msg="DownloadFile:"+"$"+"接收失败！！";
    	mHandler .removeMessages(0);
        Message m = mHandler .obtainMessage(1, 1, 1, msg);//向主线程发信，通知接收结束
        mHandler .sendMessage(m); 
    }
}

发送文件线程类：

package er.fly;

import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.SocketException;

import android.util.Log;

public class UpFile extends Thread{

	private Socket client;
    File file=null;  
    String Tag ="UpFile";
    
    public UpFile(Socket client) {  
        this.client = client;  
    }
    public void SetFile(File file){
    	
    	this.file = file;  
    }
    public void run(){
    	if(client == null)
    	{
    		return ;
    	}
    	if(client.isOutputShutdown())
    	{
    		
    		try {
				client.setKeepAlive(true);
			} catch (SocketException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				Log.i(Tag, "client setKeepAlive worry");
			}
    	}
    	FileInputStream reader = null;
    	FileInputStream readLen = null;
 
        byte[] buf = null;
    	
        try{
        	InputStream inPut = client.getInputStream();
        	OutputStream outPut = client.getOutputStream();
        	readLen = new FileInputStream(file);
        	ByteArrayOutputStream ow = new ByteArrayOutputStream();
        	int count =0;
        	int buffersize= 256;
        	int fileLen=0;
        	buf = new byte[buffersize];
        	while ((count = readLen.read(buf)) > 0)              //读取文件字节长度
        	{
        		fileLen = fileLen + count;
        	}
        	String strLen =String.valueOf(fileLen);
        	strLen = strLen+"\n";
        	Log.i(Tag, strLen);
        	byte[] buffLen = strLen.getBytes();
        	byte[] buffL = new byte[50];
        	for(int i=0;i<50;i++)                         //把文件字节长度添加到一个长度为50字节数组中   //因为服务也是一次接收50个字节
        	{
        		if(i<buffLen.length)
        		{
        			buffL[i]=buffLen[i];
        		}
        		else
        		{
        			buffL[i]= 0;
        		}
        	}
        	outPut.write(buffL);              //发送文件长度字节数组
        	outPut.flush();                   // 把网络流发送出去，否则服务器接收不到
        	count =0;
                //读取文件字节，并循环发送
        	reader = new FileInputStream(file);
        	while ((count = reader.read(buf)) > 0) 
        	{
        		ow.write(buf, 0, count);
        		Log.i(Tag, "reading file");
        	}  
        	Log.i(Tag, "开始发送！！");
        	outPut.write(ow.toByteArray());
        	outPut.flush();

        	
        	Log.i(Tag, "文件发送完成！！！");
        //    client.shutdownOutput();             //一定不能加这句话，否则socket关闭发送流，以后就不能在此发送，这也是问什么用文件字节长度来判断接收结束原因
        
        }
        catch(Exception e)
        {
        	System.out.println("socket执行异常：" + e.toString()); 
        }finally {
        	try {  
                // 结束对象  
                buf = null;  
               // out.close();        //out一定不能关闭，因为同事也会关闭socket
             //   out.close();
              //  in.close();  
                reader.close();  
               // client.close();  
            } catch (Exception e) {  
  
            }  
        }
    }
}

完整的工程下载地址（源码）：http://download.csdn.net/detail/zhujinghao09/5313666