Android應用開發基礎篇（12）-----Socket通信

一、概述

      網絡通信無論在手機還是其他設備上都應用得非常廣泛，因此掌握網絡編程是非常有必要的，而我覺得socket編程是網絡編程的基礎。在進入正題之前，先介紹幾點網絡知識，一：socket編程有分TCP和UDP兩種，TCP是基於連接的，而UDP是無連接的；二：一個TCP連接包括了輸入和輸出兩條獨立的路徑；三：服務器必須先運行然后客戶端才能與它進行通信。四：客戶端與服務器所使用的編碼方式要相同，否則會出現亂碼。下面的實現中為了講解的方便，並沒有采用多線程的方法，因此通信過程中會阻塞UI線程，而且只涉及了單向通信（客戶端-->服務器），完善的程序（多線程，雙向通信）會在提高篇再講解。

二、要求

     熟悉socket編程。

三、實現

     新建工程MyClient，修改/res/layout/main.xml文件，在里面添加一個EditText和兩個Button，完整的main.xml文件如下：

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="fill_parent"
    android:layout_height="fill_parent"
    android:orientation="vertical" >

    <EditText 
        android:id="@+id/edittext"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:hint="請輸入要發送的內容"
        />

    <Button
        android:id="@+id/connectbutton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="連接" 
        />
    
    <Button 
        android:id="@+id/sendbutton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="發送"
        />
       
    
</LinearLayout>

接着，修改MyClientActivity.java文件，定義一個socket對象和一個OutputStream對象（用於發送數據），完整的內容如下：

 

package com.nan.client;

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

import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.Toast;


public class MyClientActivity extends Activity 
{
    private EditText mEditText = null;
    private Button connectButton = null;
    private Button sendButton = null;
    
    private Socket clientSocket = null;
    private OutputStream outStream = null;
    
    
    /** Called when the activity is first created. */
    @Override
    public void onCreate(Bundle savedInstanceState) 
    {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        
        mEditText = (EditText)this.findViewById(R.id.edittext);
        connectButton = (Button)this.findViewById(R.id.connectbutton);
        sendButton = (Button)this.findViewById(R.id.sendbutton);
        sendButton.setEnabled(false);      
        
        //連接按鈕監聽
        connectButton.setOnClickListener(new View.OnClickListener() 
        {
            
            @Override
            public void onClick(View v) 
            {
                // TODO Auto-generated method stub
                try 
                {
                    //實例化對象並連接到服務器
                    clientSocket = new Socket("183.41.101.71",8888);
                } 
                catch (UnknownHostException e) 
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } 
                catch (IOException e) 
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                
                displayToast("連接成功！");            
                
                connectButton.setEnabled(false);
                sendButton.setEnabled(true);
            }
        });
        
        //發送數據按鈕監聽
        sendButton.setOnClickListener(new View.OnClickListener() 
        {
            
            @Override
            public void onClick(View v) 
            {
                // TODO Auto-generated method stub
                byte[] msgBuffer = null;
                //獲得EditTex的內容
                String text = mEditText.getText().toString();
                try {
                    //字符編碼轉換
                    msgBuffer = text.getBytes("GB2312");
                } catch (UnsupportedEncodingException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }
                            
                
                try {
                    //獲得Socket的輸出流
                    outStream = clientSocket.getOutputStream();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }                                                    
                
                
                try {
                    //發送數據
                    outStream.write(msgBuffer);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                
                displayToast("發送成功！");
            }
        });
              
        
    }
    
    //顯示Toast函數
    private void displayToast(String s)
    {
        Toast.makeText(this, s, Toast.LENGTH_SHORT).show();
    }
    
    
}

接着，新建工程MyServer，同樣修改/res/layout/main.xml文件，如下：

 

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="fill_parent"
    android:layout_height="fill_parent"
    android:orientation="vertical" >

    <TextView
        android:id="@+id/textview"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:textSize="15dip"
         
        />

</LinearLayout>

修改MyServerActivity.java文件，比較簡單，代碼中有詳細注釋，如下：

 

package com.nan.server;

import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.ServerSocket;
import java.net.Socket;

import android.app.Activity;
import android.os.Bundle;
import android.widget.TextView;


public class MyServerActivity extends Activity 
{
    private TextView mTextView = null;
    
    private InputStream mInputStream = null;
    private Socket clientSocket = null;
    private ServerSocket mServerSocket = null;
    
    /** Called when the activity is first created. */
    @Override
    public void onCreate(Bundle savedInstanceState) 
    {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        
        mTextView = (TextView)this.findViewById(R.id.textview);
        
        try {
            //實例化ServerSocket對象並設置端口號為8888
            mServerSocket = new ServerSocket(8888);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        try {
            //等待客戶端的連接（阻塞）
            clientSocket = mServerSocket.accept();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        try {
            //獲得socket的輸入流
            mInputStream = clientSocket.getInputStream();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        byte[] buf = new byte[512];  
        String str = null;
          
        try {
            //讀取輸入的數據(阻塞讀)
            mInputStream.read(buf);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        try {
            //字符編碼轉換
            str = new String(buf, "GB2312").trim();
        } catch (UnsupportedEncodingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        //顯示接收到的數據
        mTextView.setText("收到的數據："+str);
            
    }
      
}

最后在兩個工程的AndroidMainfest.xml文件中都加入權限：

 

<uses-permission android:name="android.permission.INTERNET"></uses-permission>

到這里，客戶端和服務器的程序都寫好了，在模擬器上運行客戶端程序：

 

在真機上運行服務器程序：

 

接着，點擊客戶端“連接”按鈕，輸入一些內容再點擊“發送”按鈕：

 

此時服務器端的情況如下：

 

可見成功接收了客戶端發送過來的數據。