13-6-7 android Socket客户端client双向通信的编写

package com.example.client;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;

import android.annotation.SuppressLint;
import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;

@SuppressLint("HandlerLeak")
public class MainActivity extends Activity{

	private static final String TAG = "MainActivity";
	private Button mBtnRegister;
	private TextView mTxtId;
	private EditText mEtDevice;
	private TextView mTxtIp;
	private Button mBtnConnect;
	
	private Socket socket=null;		//使用socket连接
	private BufferedReader in=null;	//缓冲数据
	private BufferedWriter out =null;
	
	private ObjectInputStream socketin=null;	//缓冲数据
	private ObjectOutputStream socketout =null;
	private Thread socketThread;
	private Thread readlineThread;
	private boolean socketIsRunning = true;
	private boolean readIsRunning = false;
	private Handler handler;
	
	
	

	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_main);
		Log.i(TAG, "-------------this is activity_main-------------");
		mBtnRegister = (Button)findViewById(R.id.register);
		mTxtId = (TextView)findViewById(R.id.id);
		mEtDevice = (EditText)findViewById(R.id.device);
		mTxtIp = (TextView)findViewById(R.id.ip);
		mBtnConnect = (Button)findViewById(R.id.connect);
		
		ClickListener c1 = new ClickListener();
		mBtnConnect.setOnClickListener(c1);
		mBtnRegister.setOnClickListener(c1);
		
		/*************************************************************************
		 * handler 事件处理
		 */
		handler = new Handler(){
			@Override
			public void handleMessage(Message msg){
				switch(msg.what){
				case 1://接收回来的数据
					Log.i(TAG, msg.toString());
					Toast.makeText(MainActivity.this, "Data:"+msg.obj, Toast.LENGTH_LONG).show();
					mTxtId.setText((String)msg.obj);
					break;
				case 2:
					readIsRunning = true;	
					socketIsRunning = false;
					readlineThread.start();
				}	
			}
		};
		
		readlineThread = new Thread(new Runnable(){
			
			public void run() {
				// TODO Auto-generated method stub
				while(readIsRunning){
					try {
						Thread.sleep(200);
					} catch (InterruptedException e1) {
						// TODO Auto-generated catch block
						e1.printStackTrace();
					}
					if(!socket.isInputShutdown()){ 
						try {
							Log.i(TAG, "read……");							
							String formServerStr=null;
							char[] buffer = new char[10];
							int count = 0;
							if((count = in.read(buffer))>0)
							{						
								Log.i(TAG, count+"");
								
								Log.i(TAG, buffer[0]+"");
								
								formServerStr = getInfoBuff(buffer, count);//消息换行
								Message msg = new Message();
				                msg.what = 1;
				                msg.obj = formServerStr;
				                handler.sendMessageDelayed(msg, 100);
							}
							/***********
							 * 这块不能接收是个极大的问题  看手册 看readline 和 read区别
							 * 
							if((formServerStr = in.readLine())!=null){//通过直接读取，会造成阻塞
								formServerStr+='\n';
								Message msg = new Message();
								msg.what = 1;
								msg.obj = formServerStr;
								Log.i(TAG, "success: "+formServerStr.toString());
								handler.sendMessageDelayed(msg, 100);
							}*/
						} catch (IOException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
					}
				}
			}
		});
		socketThread = new Thread(new Runnable(){
			public void run(){
				while(socketIsRunning){
					if(socket == null){
						try{
							socket = new Socket("10.10.100.254", 8899);		//创建 socket
							socket.setSoTimeout(3000);						//防止阻塞
							if(socket.isConnected()){
								Log.i(TAG, "socket: is created "+socket.toString());
								 
								in = new BufferedReader(new InputStreamReader(socket.getInputStream()));	
								out =new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
								
								Message msg = new Message();
								msg.what = 2;
								handler.sendMessageDelayed(msg, 120);
							}
						}catch(Exception e){
							e.printStackTrace();
							Log.i(TAG, "error: "+e.toString());
						}
					}
				}
			}
		});
	}
	
	@Override
	public boolean onCreateOptionsMenu(Menu menu) {
		// Inflate the menu; this adds items to the action bar if it is present.
		getMenuInflater().inflate(R.menu.main, menu);
		return true;
	}

	/*************************************************************************
	 * 内部监听类，监听OnClickListener事件
	 */
	class ClickListener implements OnClickListener{
		public void onClick(View v) {
			// TODO Auto-generated method stub
			if(v == mBtnConnect){
				Log.i(TAG, "connectButton is pressed");
				if(socketIsRunning == true){
					socketThread.start();
				}else{
					Toast.makeText(MainActivity.this, "socket已经连接", Toast.LENGTH_LONG).show();
				}	
			}
			/*********************
			 * register device
			 */
			if(v == mBtnRegister){
				Log.i(TAG, "register is pressed");
			}
		}
	}
	private String getInfoBuff(char[] buff, int count)
	{
		char[] temp = new char[count];
		for(int i=0; i<count; i++)
		{
			temp[i] = buff[i];
		}
		return new String(temp);
	}

}

BufferedReader buf = new BufferedReader(new FileReader("file.java"));

mark()

reset()

length

offset

buffer

mark()

byteCount