网络通信-Socket

参考:https://blog.csdn.net/hzw2017/article/details/81210979

Socket,即套接字,是一个对 TCP/IP 协议进行封装的编程调用接口(API)。

  • 位于传输层,是网络上的两个程序通过一个双向的通信连接实现数据交换的一种进程通信方式之一。
  • 成对出现,一对套接字。

Android与服务器的通信方式主要有两种,一是Http通信,一是Socket通信。两者的最大差异在于,Http连接使用的是“请求—响应方式”,即在请求时建立连接通道,当客户端向服务器发送请求后,服务器端才能向客户端返回数据。而Socket通信则是在双方建立起连接后就可以直接进行数据的传输在连接时可实现信息的主动推送,而不需要每次由客户端向服务器发送请求。

简单来说,Socket提供了程序内部与外界通信的端口并为通信双方的提供了数据传输通道。

分类

TCP/IP协议族中,Socket主要分为流套接字(StreamSocket)和数据报套接字(DatagramSocket):

  • 流套接字将TCP作为其端对端协议,提供可信赖的字节流服务。
  • 数据报套接字使用UDP协议,提供数据打包发送服务。

Socket在JAVA中的简单实现

以TCP为例。

使用步骤

客户端
  1. 创建Socket对象,指定成对的服务端IP地址和端口号。
  2. 通过Socket获取输出流,写入数据发给服务端。
  3. 通过Socket获取输入流,接受服务端的发送的数据。
  4. 关闭资源close。
服务端
  1. 创建ServerSocket对象,并指定端口号,其端口号必须与客户端一致。
  2. 通过ServerSocket对象,获取客户端的Socket实例(ServerSocket.accept()方法)。
  3. 通过Socket获取输入流,接受客户端发来的消息。
  4. 通过Socket获取输出流,写入数据向客户端发送数据作为回应。
  5. 关闭资源close。

Socket在Android中

基于TCP协议

  1. 服务器端首先声明一个ServerSocket对象并指定监听的端口号。调用ServerSocket的accept()方法接收客户端的数据。accept()方法在没有数据进行接收时处于阻塞状态。
// 创建一个ServerSocket对象,指定端口为7777
ServerSocket serverSocket = new ServerSocket(7777);  

// 调用ServerSocket的accept()方法,接受客户端所发送的请求
// 如果客户端没有发送数据,那么该线程就停滞不继续
Socket socket = serverSocket.accept();
  1. 一旦接收到数据,通过InputStream读取接收的数据。
// 从Socket当中得到InputStream对象
InputStream inputStream = socket.getInputStream(); 

byte buffer[] = new byte[1024 * 4];  
int temp = 0;  
// 从InputStream当中读取客户端所发送的数据  
while ((temp = inputStream.read(buffer)) != -1) {  
  System.out.println(new String(buffer, 0, temp));  
} 
  1. 客户端创建一个Socket对象,指定服务端的IP和端口号,通过InputSream读取数据,获取服务器发出的数据。
// 创建一个Socket对象,并指定服务端的IP及端口号
Socket socket = new Socket(ip, 7777);

// 创建一个InputStream用户读取要发送的文件
InputStream inputStream = new FileInputStream("xxx");
  1. 最后将要发送的数据写入到OutputStream,即可进行TCP协议的Socket数据传输。
// 获取Socket的OutputStream对象用于发送数据。  
OutputStream outputStream = socket.getOutputStream();  

// 创建一个byte类型的buffer字节数组,用于存放读取的本地文件  
byte buffer[] = new byte[4 * 1024];  
int temp = 0;  
// 循环读取文件  
while ((temp = inputStream.read(buffer)) != -1) {  
  // 把数据写入到OuputStream对象中  
  outputStream.write(buffer, 0, temp);  
}  
// 发送读取的数据到服务端  
outputStream.flush();

基于UDP协议

  1. 服务器端首先创建一个DatagramSocket对象,并指定监听的端口号。创建一个空的DatagramSocket对象用于接收数据(byte[] data=new byte[1024]; DatagramSocket socket=new DatagramSocket(data, data.length)),使用DatagramSocket的receive()方法接收客户端发送的数据。receive()与ServerSocket.accept()类似,在没有数据进行接收时处于阻塞状态。
    DatagramSocket socket;
    try {
        // 创建DatagramSocket对象并指定一个端口号,
        // 注意:如果客户端需要接收服务器的返回数据,  还需要使用这个端口号来receive
        socket = new DatagramSocket(1985);
        // 使用InetAddress(Inet4Address).getByName把IP地址转换为网络地址
        InetAddress serverAddress = InetAddress.getByName("192.168.1.32");  
        // Inet4Address serverAddress = (Inet4Address) Inet4Address.getByName("192.168.1.32");
        // 设置要发送的报文
        String str = "[2143213;21343fjks;213]";
        // 把字符串str字符串转换为字节数组
        byte data[] = str.getBytes();
        // 创建一个DatagramPacket对象,用于发送数据。
        // 参数一:要发送的数据,参数二:数据的长度,参数三:服务端的网络地址,参数四:服务器端端口号
        DatagramPacket packet = new DatagramPacket(data, data.length, serverAddress, 10025);
        // 把数据发送到服务端。
        socket.send(packet);    
    } catch (SocketException e) {  
        e.printStackTrace();  
    } catch (UnknownHostException e) {  
        e.printStackTrace();  
    } catch (IOException e) {  
        e.printStackTrace();  
    }  
  1. 客户端也创建一个DatagramSocket对象,并指定端口。创建一个InetAddress对象,该对象类似于一个网络的发送地址(InetAddress ia=InetAddress.getByName(ip)),定义要发送的字符串,创建一个DatagramPacket对象,并指定要将该数据包发送到网络的哪个IP及端口号,最后使用DatagramSocket的send()方法发送数据。(String str="hello"; byte[] data=str.getByte(); DatagramPacket packet=new DatagramPacket(data, data.length, serveraddress, port); socket.send(packet);)
    DatagramSocket socket;  
    try {  
        // 实例化的端口号要和发送时的socket一致,否则收不到data  
        socket = new DatagramSocket(1985);  
        byte data[] = new byte[4 * 1024];  
        // 参数一:要接受的data,参数二:data的长度  
        DatagramPacket packet = new DatagramPacket(data, data.length);  
        socket.receive(packet);  
        // 把接收到的data转换为String字符串  
        String result = new String(packet.getData(), packet.getOffset(), packet.getLength());
        // 不使用了记得要关闭
        socket.close();  
        System.out.println("the number of reveived Socket is  :" + flag  
                + "udpData:" + result);  
    } catch (SocketException e) {  
        e.printStackTrace();  
    } catch (IOException e) {  
        e.printStackTrace();  
    }  
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,884评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,347评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,435评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,509评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,611评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,837评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,987评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,730评论 0 267
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,194评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,525评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,664评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,334评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,944评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,764评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,997评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,389评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,554评论 2 349