Android 学习 笔记_10. Socket 编程

1、Socket是一种网络通信的接口。称“套接字”，用于描述IP地址和端口，是一个通信链的句柄。

     应用程序通常通过“套接字”向网络发出请求或者应答网络请求，分为服务器端请求和客户端请求。

2、Socket的通信模型

       

UDP：发送后就不管结果，一个数据包发送是有限的；速度快

TCP：发送数据要求接收方接受到数据后给回应，且无限制的；速度慢

                     

 main.xml

<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context=".SocketActivity" >

    <Button
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:layout_centerHorizontal="true"
        android:layout_centerVertical="true"
        android:id="@+id/start"
        android:text="@string/start" />

</RelativeLayout>

SocketActivity.java

package zzl.socket_main;

import java.io.IOException;
import java.io.InputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.ServerSocket;
import java.net.Socket;

import android.app.Activity;
import android.os.Bundle;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;

public class SocketActivity extends Activity {

    private Button start=null;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        
        start=(Button)findViewById(R.id.start);
        start.setOnClickListener(new StartSocketListener());
    }

    class StartSocketListener implements OnClickListener{

        @Override
        public void onClick(View v) {
            // TODO Auto-generated method stub
            //启动一个线程
            new ServerThread().start();
        }
    }
    class ServerThread extends Thread{
        /*public void run(){
            //声明一个ServerSocket对象
            ServerSocket serverSocket=null;
            try{
                //创建一个ServerSocket对象，
                //并让这个Socket在4567端口监听
                 serverSocket =new ServerSocket(4567);
                 //调用ServerSocket的accept方法，接收客户端所发送的请求
                //阻塞方法：如果客户端没有发送请求，则阻塞，否则返回Socket对象
                 Socket socket =serverSocket.accept();
                 
                 //从Socket当中得到InputStream对象
                 //通过InputStream来传递数据
                 InputStream inputStream=socket.getInputStream();
                 byte buffer[]=new byte[1024*4];
                 int temp=0;
                 while ((temp=inputStream.read(buffer))!=-1){
                     System.out.println(new String(buffer,0,temp));
                 }
            }catch(IOException e){
                e.printStackTrace();
            }//最后记得把serverSocket给关掉
            finally{
                try{
                    serverSocket.close();
                }catch(IOException e){
                    e.printStackTrace();
                }
            }
        }*/
    
    public void run(){
      try{
        //创建一个DatagramSocket对象，并指定监听的端口号
        DatagramSocket socket =new DatagramSocket(4567);
        byte data[]=new byte[1024];
        //创建一个空的DatagramPacket对象
        DatagramPacket packer=new DatagramPacket(data, data.length);
        //使用receive方法接收客户端所发送的数据
        socket.receive(packer);
        String result=new String(packer.getData());
        System.out.println("result--->"+result);
        }catch(IOException e){
            e.printStackTrace();
        }
    }
    
    }
    @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;
    }

}

TCPCLient.java

package zzl.socket_client;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

import android.app.Activity;

public class TCPClient extends Activity {
    public static void main(String[] arge){
        try{
            //创建一个SOCket对象，指定服务器端的IP地址和端口号
            Socket socket =new Socket("192",4567);
            //使用inputStream读取硬盘上的文件
            InputStream inputStream=new FileInputStream("f://file"); 
            //从Socket当当中得到OutputStream
            OutputStream outputStream=socket.getOutputStream();
            byte buffer []=new byte[4*1024];
            int temp=0;
            //从inputStream发送出来，传送到outputStream
            while((temp=inputStream.read())!=-1){
                outputStream.write(buffer,0,temp);
            }
            outputStream.flush();
        }catch(IOException e){
            e.printStackTrace();
        }
    }
    
}

UDPClient.java

package zzl.socket_client;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPClient {
    public static void main(String[] arge){
        try{
            //创建一个DatagramSocket对象
            DatagramSocket socket =new DatagramSocket(4567);
            //创建一个InetAddress：要发送的地址
            InetAddress serverAddress=InetAddress.getByName("192"); 
            String str="hello";
            byte data []=str.getBytes();
            //创建一个DatagramPacket对象，并自定要将这个数据包发送到网络当中的哪个地址以及端口号：发送数据对象
            DatagramPacket packer=new DatagramPacket(data,data.length,serverAddress,4567);
            //调用Socket对象的send方法发送数据
            socket.send(packer);
        }catch(IOException e){
            e.printStackTrace();
        }
    }
    
}

总结：

   （1、客户端和服务端是两个不同的项目，而且这个程序需要在手机上实时测试的。

   （2、还是存在着一些问题，需要好好再了解一下