Android Socket编程基础

前些天写了一个Android手机在局域网内利用Wifi进行文件传输的Demo,其中用到了Socket编程,故此总结(盗了网友的一些图和文字)。好久好久没来博客园了~~

1.什么是Socket?

socket英文意思是插座,只有插上插座,才会有电流。如果把他用在网络中,只有建立了socket连接,才能传输数据。网络中的进程是通过socket来通信的,socket起源于Unix,而Unix/Linux基本哲学之一就是“一切皆文件”,都可以用“打开open –> 读写write/read –> 关闭close”模式来操作。

我的理解就是Socket就是该模式的一个实现,socket即是一种特殊的文件,一些socket函数就是对其进行的操作(读/写IO、打开、关闭)

 2.使用Socket进行网络通信的过程

Socket通讯的过程大概可以简述为

建立Socket连接-->获得输入/输出流-->读/写数据-->关闭输入/输出流-->关闭Socket

 2.1 Socket 建立连接过程

我们知道tcp建立连接要进行“三次握手”,即交换三个分组。大致流程如下:

  • 客户端向服务器发送一个SYN J
  • 服务器向客户端响应一个SYN K,并对SYN J进行确认ACK J+1
  • 客户端再想服务器发一个确认ACK K+1

示意图如下:

Android Socket编程基础

从图中可以看出,当客户端调用connect时,触发了连接请求,向服务器发送了SYN J包,这时connect进入阻塞状态;服务器监听到连接请求,即收到SYN J包,调用accept函数接收请求向客户端发送SYN K ,ACK J+1,这时accept进入阻塞状态;

客户端收到服务器的SYN K ,ACK J+1之后,这时connect返回,并对SYN K进行确认;服务器收到ACK K+1时,accept返回,至此三次握手完毕,连接建立。

 2.2 获取Socket文件流进行数据通讯

图例:

Android Socket编程基础

服务端:

ServerSocket serverSocket = new ServerSocket(PORT);
Socket client = serverSocket.accept();// accept()方法监听向这个socket的连接并接收连接。它将会阻塞直到连接被建立好。连接建立好后它会返回一个Socket对象。

InputStream inputstream = client.getInputStream();//获取数据输入流

byte [] data=new byte[4096];

inputstream.read(data);//读入数据

客户端:

Socket socket = new Socket();

try {
      socket.bind(null);
      socket.connect((new InetSocketAddress(host, port)), SOCKET_TIMEOUT);//指定ip和端口 建立连接,参数 host为IP地址,port为端口名

OutputStream stream = socket.getOutputStream(); //获取文件输出流

stream.write(“socket data”); //向Socket 写入数据

} catch (IOException e) {
        Log.e(TAG, e.getMessage());
} finally {
      if (socket != null) {
      if (socket.isConnected()) {
      try {
      socket.close();//关闭socket
      } catch (IOException e) {
      e.printStackTrace();

}
}

3.使用线程实现服务器端与客户端的双向通信

在应用中,数据通讯肯定是有来有回的,那么我们就要结合多线程技术使用Socket 

设计思想是,用两个线程,一个线程专门用于处理服务器端的读,另一个线程专门用于处理服务器端的写。客户端同理。

代码如下,程序共有六个类。

 

服务器端和其输入输出线程:

package com.example.network;

import java.net.ServerSocket;
import java.net.Socket;

public class MainServer
{
public static void main(String[] args) throws Exception
{
ServerSocket serverSocket = new ServerSocket(4000);

while (true)
{
// 一直处于监听状态,这样可以处理多个用户
Socket socket = serverSocket.accept();

// 启动读写线程
new ServerInputThread(socket).start();
new ServerOutputThread(socket).start();

}

}

}

package com.example.network;

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

public class ServerInputThread extends Thread
{
private Socket socket;

public ServerInputThread(Socket socket)
{
super();
this.socket = socket;
}

@Override
public void run()
{
try
{
// 获得输入流
InputStream is = socket.getInputStream();

while (true)
{
byte[] buffer = new byte[1024];

int length = is.read(buffer);

String str = new String(buffer, 0, length);

System.out.println(str);

}

}
catch (IOException e)
{
e.printStackTrace();
}
}

}

package com.example.network;

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

public class ServerOutputThread extends Thread
{
private Socket socket;

public ServerOutputThread(Socket socket)
{
super();
this.socket = socket;
}

@Override
public void run()
{
try
{

OutputStream os = socket.getOutputStream();

while (true)
{
BufferedReader reader = new BufferedReader(
new InputStreamReader(System.in));

String line = reader.readLine();

os.write(line.getBytes());
}
}
catch (IOException e)
{
e.printStackTrace();
}

}

}

 

客户端和其输入输出线程(其输入输出线程和服务器端的完全一样):  

package com.example.network;

import java.net.Socket;

public class MainClient
{

public static void main(String[] args) throws Exception
{
Socket socket = new Socket("127.0.0.1", 4000);

new ClientInputThread(socket).start();
new ClientOutputThread(socket).start();

}
}

package com.example.network;

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

public class ClientInputThread extends Thread
{
private Socket socket;

public ClientInputThread(Socket socket)
{
super();
this.socket = socket;
}

@Override
public void run()
{
try
{
// 获得输入流
InputStream is = socket.getInputStream();

while (true)
{
byte[] buffer = new byte[1024];

int length = is.read(buffer);

String str = new String(buffer, 0, length);

System.out.println(str);

}

}
catch (IOException e)
{
e.printStackTrace();
}
}

}

package com.example.network;

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

public class ClientOutputThread extends Thread
{
private Socket socket;

public ClientOutputThread(Socket socket)
{
super();
this.socket = socket;
}

@Override
public void run()
{
try
{

OutputStream os = socket.getOutputStream();

while (true)
{
BufferedReader reader = new BufferedReader(
new InputStreamReader(System.in));

String line = reader.readLine();

os.write(line.getBytes());
}
}
catch (IOException e)
{
e.printStackTrace();
}

}

}

 

上一篇:机器学习 —— log-linear 模型


下一篇:[LeetCode]60. Permutation Sequence求全排列第k个