热门标签 | HotTags
当前位置:  开发笔记 > 运维 > 正文

Java的Socket网络编程基础知识入门教程

这篇文章主要介绍了Java的Socket网络编程基础知识入门教程,包括基于TCPIP和UDP协议的简单实例程序讲解,需要的朋友可以参考下

一、TCP/IP简介

TCP/IP协议族是互联网使用的协议,也可以用在独立的专用网络中。
TCP/IP协议族包括了IP协议、TCP协议和UDP协议。

IP协议使用IP地址来分发报文,但它是尽力而为的服务,报文可能丢失、乱序或者
重复发送。TCP和UDP协议在IP协议基础上增加了端口号,从而在两台主机的应用
程序间建立起透明的连接。

不同的是,TCP协议会对IP层的错误进行修复,它通过握手消息在主机间建立连接,
之后通过在消息中加入序列号来恢复消息中的错误。而UDP只是简单地扩展了IP协议,
使它能够在应用程序之间工作,而不是主机之间。

关于IP地址,一台主机可以有多个网络接口,而一个接口又可以有多个地址。
有些IP地址是有特殊用途的:

A.回环地址:127.0.0.1,总是被分配给一个回环接口,主要用于测试。

B.私有地址:以10、192.168、172.(16-31)开头,用于私有网络。NAT设备转发报文
时,将一个接口中报文的私有地址端口对映射成另一个接口中的公有地址端口对。这
就使一小组主机能够共享一个IP地址对。

C.多播地址:第一个数字在224~239之间。

二、Socket基础

1.地址的获得

public static void main(String[] args) { 
 
  try { 
    Enumeration interfaces = NetworkInterface.getNetworkInterfaces(); 
    while (interfaces.hasMoreElements()) { 
      NetworkInterface iface = interfaces.nextElement(); 
      System.out.println("Interface: " + iface.getName()); 
       
      Enumeration addrList = iface.getInetAddresses(); 
      if (!addrList.hasMoreElements()) 
        System.out.println("No address"); 
       
      while (addrList.hasMoreElements()) { 
        InetAddress address = addrList.nextElement(); 
        System.out.println("Address: " + address.getHostAddress()); 
      } 
    } 
     
  } catch (SocketException e) { 
    e.printStackTrace(); 
  } 
   
} 

2.TCP实例程序

要注意一点,虽然在Client端只用了一个write()方法发送字符串,服务器端也可能从
多个块中接受该信息。即使回馈字符串在服务器返回时存于一个块中,也可能被TCP
协议分割成多个部分。

TCPEchoClientTest.java

public static void main(String[] args) throws IOException { 
 
  String server = args[0]; 
  byte[] data = args[1].getBytes(); 
  int port = 7; 
   
  Socket socket = new Socket(server, port); 
  System.out.println("Connected to server..."); 
   
  InputStream in = socket.getInputStream(); 
  OutputStream out = socket.getOutputStream(); 
   
  out.write(data); 
   
  int totalBytesRcvd = 0; 
  int bytesRcvd; 
  while (totalBytesRcvd 

TCPEchoServerTest.java

private static final int BUFSIZE = 32; 
 
public static void main(String[] args) throws IOException { 
 
  ServerSocket serverSocket = new ServerSocket(7); 
   
  int recvMsgSize; 
  byte[] receiveBuf = new byte[BUFSIZE]; 
  while (true) { 
    Socket socket = serverSocket.accept(); 
    System.out.println("Handling client " + 
        " from remote " + socket.getRemoteSocketAddress() +  
        " at local " + socket.getLocalSocketAddress()); 
     
    InputStream in = socket.getInputStream(); 
    OutputStream out = socket.getOutputStream(); 
     
    while ((recvMsgSize = in.read(receiveBuf)) != -1) { 
      out.write(receiveBuf, 0, recvMsgSize); 
    } 
    socket.close(); 
  } 
   
} 

注意new Socket时指定的是远端服务器监听的端口号而没有指定本地端口,因此将
采用默认地址和可用的端口号。在我的机器上Client端口是4593,连接到服务器的
端口7。


3.UDP实例程序

为什么使用UDP协议?如果应用程序只交换少量的数据,TCP连接的建立阶段就至少
要传输其两倍的信息量(还有两倍的往返时间)。

UDPEchoClientTest.java

public static void main(String[] args) throws IOException { 
 
  InetAddress serverAddress = InetAddress.getByName(args[0]); 
  byte[] bytesToSend = args[1].getBytes(); 
   
  DatagramSocket socket = new DatagramSocket(); 
  socket.setSoTimeout(3000); 
   
  DatagramPacket sendPacket = new DatagramPacket( 
    bytesToSend, bytesToSend.length, serverAddress, 7); 
   
  DatagramPacket receivePacket = new DatagramPacket( 
    new byte[bytesToSend.length], bytesToSend.length); 
   
  // Packets may be lost, so we have to keep trying 
  int tries = 0; 
  boolean receivedRespOnse= false; 
  do { 
    socket.send(sendPacket); 
    try { 
      socket.receive(receivePacket); 
      if (!receivePacket.getAddress().equals(serverAddress)) 
        throw new IOException("Receive from unknown source"); 
      receivedRespOnse= true; 
    }  
    catch (IOException e) { 
      tries++; 
      System.out.println("Timeout, try again"); 
    } 
  } while (!receivedResponse && tries <5); 
   
  if (receivedResponse) 
    System.out.println("Received: " + new String(receivePacket.getData())); 
  else 
    System.out.println("No response"); 
   
  socket.close(); 
} 

UDPEchoServerTest.java

private static final int ECHOMAX = 255;  
 
public static void main(String[] args) throws IOException { 
 
  DatagramSocket socket = new DatagramSocket(7); 
  DatagramPacket packet = new DatagramPacket(new byte[ECHOMAX], ECHOMAX); 
   
  while (true) { 
    socket.receive(packet); 
    System.out.println("Handling client at " + packet.getAddress()); 
     
    socket.send(packet); 
    packet.setLength(ECHOMAX); 
  } 
   
} 

通过这个例子与之前TCP的实例进行比较,有如下区别:

A.DatagramSocket在创建时不需要指定目的地址,因为UDP不需要建立连接,每个
数据报文都可以发送或接收于不同的目的地址。

B.如果像TCP一样在read()上阻塞等待,将可能永远阻塞在那里,因为UDP协议只是
简单地扩展了IP协议,UDP报文可能丢失掉。所以一定要设置阻塞等待的超时时间。

C.UDP协议保留了消息的边界信息,每次receive()调用最多只能接收一次send()方法
调用所发送的数据。

D.一个UDP报文DatagramPacket能传输的最大数据是65507字节,超出部分的字节将
自动被丢弃,而且对接收程序也没有任何的提示。因此缓存数组可以设置成65000字节
左右是安全的。

E.如果反复使用同一个DatagramPacket实例调用receive()方法,每次调用前都必须显式
地将消息的内部长度重置为缓存区的实际长度。


推荐阅读
  • 随着网络安全威胁的不断演变,电子邮件系统成为攻击者频繁利用的目标。本文详细探讨了电子邮件系统中的常见漏洞及其潜在风险,并提供了专业的防护建议。 ... [详细]
  • 本文介绍如何在现有网络中部署基于Linux系统的透明防火墙(网桥模式),以实现灵活的时间段控制、流量限制等功能。通过详细的步骤和配置说明,确保内部网络的安全性和稳定性。 ... [详细]
  • 作者:守望者1028链接:https:www.nowcoder.comdiscuss55353来源:牛客网面试高频题:校招过程中参考过牛客诸位大佬的面经,但是具体哪一块是参考谁的我 ... [详细]
  • 深入解析TCP/IP五层协议
    本文详细介绍了TCP/IP五层协议模型,包括物理层、数据链路层、网络层、传输层和应用层。每层的功能及其相互关系将被逐一解释,帮助读者理解互联网通信的原理。此外,还特别讨论了UDP和TCP协议的特点以及三次握手、四次挥手的过程。 ... [详细]
  • 本文深入探讨了MAC地址与IP地址绑定策略在网络安全中的应用及其潜在风险,同时提供了针对该策略的破解方法和相应的防御措施。 ... [详细]
  • 优化联通光猫DNS服务器设置
    本文详细介绍了如何为联通光猫配置DNS服务器地址,以提高网络解析效率和访问体验。通过智能线路解析功能,域名解析可以根据访问者的IP来源和类型进行差异化处理,从而实现更优的网络性能。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 深入理解 SQL 视图、存储过程与事务
    本文详细介绍了SQL中的视图、存储过程和事务的概念及应用。视图为用户提供了一种灵活的数据查询方式,存储过程则封装了复杂的SQL逻辑,而事务确保了数据库操作的完整性和一致性。 ... [详细]
  • 本文详细介绍了Java编程语言中的核心概念和常见面试问题,包括集合类、数据结构、线程处理、Java虚拟机(JVM)、HTTP协议以及Git操作等方面的内容。通过深入分析每个主题,帮助读者更好地理解Java的关键特性和最佳实践。 ... [详细]
  • 如何配置Unturned服务器及其消息设置
    本文详细介绍了Unturned服务器的配置方法和消息设置技巧,帮助用户了解并优化服务器管理。同时,提供了关于云服务资源操作记录、远程登录设置以及文件传输的相关补充信息。 ... [详细]
  • 网络攻防实战:从HTTP到HTTPS的演变
    本文通过一系列日记记录了从发现漏洞到逐步加强安全措施的过程,探讨了如何应对网络攻击并最终实现全面的安全防护。 ... [详细]
  • MQTT技术周报:硬件连接与协议解析
    本周开发笔记重点介绍了在新项目中使用MQTT协议进行硬件连接的技术细节,涵盖其特性、原理及实现步骤。 ... [详细]
  • 360SRC安全应急响应:从漏洞提交到修复的全过程
    本文详细介绍了360SRC平台处理一起关键安全事件的过程,涵盖从漏洞提交、验证、排查到最终修复的各个环节。通过这一案例,展示了360在安全应急响应方面的专业能力和严谨态度。 ... [详细]
  • 本文详细分析了Hive在启动过程中遇到的权限拒绝错误,并提供了多种解决方案,包括调整文件权限、用户组设置以及环境变量配置等。 ... [详细]
  • 解决MongoDB Compass远程连接问题
    本文记录了在使用阿里云服务器部署MongoDB后,通过MongoDB Compass进行远程连接时遇到的问题及解决方案。详细介绍了从防火墙配置到安全组设置的各个步骤,帮助读者顺利解决问题。 ... [详细]
author-avatar
mobiledu2502878157
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有