Android网络应用之Socket(一)

        android:id="@+id/btn_conn"/>
    <EditText 
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:hint="请在这里编辑要发送的内容"
        android:id="@+id/et_message"/>
    
    <Button 
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="发送"
        android:id="@+id/btn_sent"/>
    
    <TextView 
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:id="@+id/tv"
        android:hint="接收发来的数据"/>
</LinearLayout>

package com.example.mysocketdemo;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
import java.net.UnknownHostException;

import android.app.Activity;
import android.app.ActionBar;
import android.app.Fragment;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.text.Editable;
import android.view.LayoutInflater;
import android.view.Menu;
import android.view.MenuItem;
import android.view.View;
import android.view.ViewGroup;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
import android.os.Build;

public class MainActivity extends Activity {
	private TextView tv;
	private Button btnsent,btnconn;
	private EditText ed_message;
	private OutputStream output;
	private Socket clientSocket;
	private Handler mHandler;
	private MyThread mythread;
	boolean stop = true;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        if (savedInstanceState == null) {
            getFragmentManager().beginTransaction()
                    .add(R.id.container, new PlaceholderFragment())
                    .commit();
        }
        init();
        //onClickEvent---connect
        btnconn.setOnClickListener(new View.OnClickListener() {
			@Override
			public void onClick(View v) {
				// TODO Auto-generated method stub
				try {
					clientSocket = new Socket("127.0.0.1", 8888);
				} catch (UnknownHostException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				Toast.makeText(getApplicationContext(), "connect ok", Toast.LENGTH_SHORT).show();
				//把socket绑定到自己的线程对象
				try {
					mythread = new MyThread(clientSocket);
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				mythread.start();//启动线程
				
				//更新UI，大部分的数据工作已经交给了mythread对象
				btnsent.setEnabled(true);
				btnconn.setEnabled(false);
				stop = false;
			}
		});
        //sent Message
        btnsent.setOnClickListener(new View.OnClickListener() {
			
			@Override
			public void onClick(View v) {
				// TODO Auto-generated method stub
				//当点击按钮时,会获取编辑框中的数据,然后提交给线程
				//先将发送内容进行打包
				byte[]  msgBuffer = null;
				try {
					msgBuffer = ed_message.getText().toString().getBytes("GB2312");
				} catch (UnsupportedEncodingException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				//打包完成之后,添加socket的输出流对象
				try {
					output = clientSocket.getOutputStream();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				try {
					//输出流对象将字节写入
					//无论是输出流还是输入流，操作的都是字节,如果向变成字符串,需要自己构建String对象
					output.write(msgBuffer);
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				Toast.makeText(getApplicationContext(), "发送成功", Toast.LENGTH_SHORT).show();
				ed_message.setText("");
			}
		});
        
        //在连接和发送数据之后，接下来就是处理了,发送的数据会通过message的方式传递到消息队列,再由handl进行获取
        mHandler = new Handler(){
        	public void handleMessage(android.os.Message msg) {
        		tv.setText(msg.obj.toString());
        	};
        };
    }
    public void init()
    {
    	tv = (TextView) findViewById(R.id.tv);
    	btnsent = (Button) findViewById(R.id.btn_sent);
    	ed_message = (EditText) findViewById(R.id.et_message);
    	btnconn = (Button) findViewById(R.id.btn_conn);
    	btnconn.setEnabled(true);
    	btnsent.setEnabled(false);
    }

    //自定义线程类;
    private class MyThread extends Thread{
    	//构建自己的socket对象,用来在线程内使用
    	private Socket socket;
    	private byte[] buf = null;
    	private InputStream inputstream;
    	String str = null;
    	public MyThread(Socket socket) throws IOException
    	{
    		this.socket = socket;
    		inputstream = this.socket.getInputStream();
    	}
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
    		while(!stop)
    		{
    			buf = new byte[512];
    			//将inputstream内的数据读到buf里
    			try {
					this.inputstream.read(buf);
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
    			try {
    				//将buf里的字符流进行解析,得到
					this.str = new String(buf, "GB2312").trim();
				} catch (UnsupportedEncodingException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
    			//线程内获取了来自socket的Inputstream字节流,并且转换成字符串后，线程就获取了消息的实体内容
    			//此时线程将执行自己的一个使命，就是创建消息，并发送出去
    			Message msg = new Message();
    			msg.obj = this.str;
    			mHandler.sendMessage(msg);
    		}
    	}
    }
    
    @Override
    protected void onDestroy() {
    	// TODO Auto-generated method stub
    	if (mythread!=null) {
			mythread.interrupt();
		}
    	super.onDestroy();
    }

版权声明：本文为博主原创文章，未经博主允许不得转载。