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

 更新时间:2016年01月19日 08:49:09   作者:cdai  
这篇文章主要介绍了Java的Socket网络编程基础知识入门教程,包括基于TCP/IP和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<NetworkInterface> interfaces = NetworkInterface.getNetworkInterfaces(); 
    while (interfaces.hasMoreElements()) { 
      NetworkInterface iface = interfaces.nextElement(); 
      System.out.println("Interface: " + iface.getName()); 
       
      Enumeration<InetAddress> 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 < data.length) { 
    if ((bytesRcvd = in.read(data, totalBytesRcvd,  
        data.length - totalBytesRcvd)) == -1) 
      throw new SocketException("Connection closed"); 
    totalBytesRcvd += bytesRcvd; 
  } 
   
  System.out.println("Received: " + new String(data)); 
   
  socket.close(); 
} 

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()方法,每次调用前都必须显式
地将消息的内部长度重置为缓存区的实际长度。

相关文章

  • Spring如何集成ibatis项目并实现dao层基类封装

    Spring如何集成ibatis项目并实现dao层基类封装

    这篇文章主要介绍了Spring如何集成ibatis项目并实现dao层基类封装,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-09-09
  • java中关于转义字符的一个bug

    java中关于转义字符的一个bug

    本文主要介绍了java中关于转义字符的一个bug。具有很好的参考价值,下面跟着小编一起来看下吧
    2017-02-02
  • java后台实现js关闭本页面,父页面指定跳转或刷新操作

    java后台实现js关闭本页面,父页面指定跳转或刷新操作

    这篇文章主要介绍了java后台实现js关闭本页面,父页面指定跳转或刷新操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-11-11
  • Spring boot 整合CXF开发web service示例

    Spring boot 整合CXF开发web service示例

    这篇文章主要介绍了Spring boot 整合CXF开发web service示例,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • HttpClient POST请求第三方接口问题(多参数传参)

    HttpClient POST请求第三方接口问题(多参数传参)

    这篇文章主要介绍了HttpClient POST请求第三方接口问题(多参数传参),具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • java list去重操作实现方式

    java list去重操作实现方式

    Java中的List是可以包含重复元素的(hash code 和equals),接下来将介绍两种方式实现java list去重操作,感兴趣的朋友可以参考下
    2012-12-12
  • Java加密算法RSA代码实例

    Java加密算法RSA代码实例

    这篇文章主要介绍了Java加密算法RSA代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • Java网络编程之URL+URLconnection使用方法示例

    Java网络编程之URL+URLconnection使用方法示例

    这篇文章主要介绍了Java网络编程之URL+URLconnection使用方法示例,还是比较不错的,这里分享给大家,供需要的朋友参考。
    2017-11-11
  • Java中的interrupted()和isInterrupted()

    Java中的interrupted()和isInterrupted()

    这篇文章主要介绍了Java中的interrupted()和isInterrupted()摸下面文章围绕interrupted()和isInterrupted()的相关资料展开详细内容,需要的小伙伴乐意参考下面下面文章具体价绍,希望对大家有所帮助
    2021-11-11
  • Java反转字符串和相关字符编码的问题解决

    Java反转字符串和相关字符编码的问题解决

    反转字符串一直被当作是简单问题,大家的思想主要就是利用遍历,首尾交换字符实现字符串的反转。例如下面的代码,就可以简单实现反转。
    2013-05-05

最新评论