socket编程详解(Java TCP/IP Socket编程)

-> 是结构体指针变量引用结构体成员变量的方法。 一般结构体引用成员变量用.(点)。struct stu {char name[10];int age ;} s, *p=s ;strcpy( s.name , "Jack" );s.age=20 ;也可以用指针来操作strcpy( p->name , "Jack" );p->age=20 ; 当指向s时，与上面两句等价。

Java网络编程精解之ServerSocket用法详解一 第3章 ServerSocket用法详解 第10章 Java语言的反射机制 第13章 基于MVC和RMI的分布 ServerSocket用法详解一Java语言的反射机制一基于MVC和RMI的分布式应用一ServerSocket用法详解二Java语言的反射机制二基于MVC和RMI的分布式应用二ServerSocket用法详解三在客户/服务器通信模式中，服务器端需要创建监听特定端口的ServerSocket，ServerSocket负责接收客户连接请求。本章首先介绍ServerSocket类的各个构造方法，以及成员方法的用法，接着介绍服务器如何用多线程来处理与多个客户的通信任务。本章提供线程池的一种实现方式。线程池包括一个工作队列和若干工作线程。服务器程序向工作队列中加入与客户通信的任务，工作线程不断从工作队列中取出任务并执行它。本章还介绍了java.util.concurrent包中的线程池类的用法，在服务器程序中可以直接使用它们。3.1构造ServerSocketServerSocket的构造方法有以下几种重载形式：◆ServerSocket()throws IOException◆ServerSocket(int port) throws IOException◆ServerSocket(int port, int backlog) throws IOException◆ServerSocket(int port, int backlog, InetAddress bindAddr) throws IOException在以上构造方法中，参数port指定服务器要绑定的端口（服务器要监听的端口），参数backlog指定客户连接请求队列的长度，参数bindAddr指定服务器要绑定的IP地址。3.1.1绑定端口除了第一个不带参数的构造方法以外，其他构造方法都会使服务器与特定端口绑定，该端口由参数port指定。例如，以下代码创建了一个与80端口绑定的服务器：ServerSocket serverSocket=new ServerSocket(80);如果运行时无法绑定到80端口，以上代码会抛出IOException，更确切地说，是抛出BindException，它是IOException的子类。BindException一般是由以下原因造成的：◆端口已经被其他服务器进程占用；◆在某些操作系统中，如果没有以超级用户的身份来运行服务器程序，那么操作系统不允许服务器绑定到1~1023之间的端口。如果把参数port设为0，表示由操作系统来为服务器分配一个任意可用的端口。由操作系统分配的端口也称为匿名端口。对于多数服务器，会使用明确的端口，而不会使用匿名端口，因为客户程序需要事先知道服务器的端口，才能方便地访问服务器。在某些场合，匿名端口有着特殊的用途，本章3.4节会对此作介绍。3.1.2设定客户连接请求队列的长度当服务器进程运行时，可能会同时监听到多个客户的连接请求。例如，每当一个客户进程执行以下代码：Socket socket=new Socket(www.javathinker.org,80);就意味着在远程www.javathinker.org主机的80端口上，监听到了一个客户的连接请求。管理客户连接请求的任务是由操作系统来完成的。操作系统把这些连接请求存储在一个先进先出的队列中。许多操作系统限定了队列的最大长度，一般为50。当队列中的连接请求达到了队列的最大容量时，服务器进程所在的主机会拒绝新的连接请求。只有当服务器进程通过ServerSocket的accept()方法从队列中取出连接请求，使队列腾出空位时，队列才能继续加入新的连接请求。对于客户进程，如果它发出的连接请求被加入到服务器的队列中，就意味着客户与服务器的连接建立成功，客户进程从Socket构造方法中正常返回。如果客户进程发出的连接请求被服务器拒绝，Socket构造方法就会抛出ConnectionException。ServerSocket构造方法的backlog参数用来显式设置连接请求队列的长度，它将覆盖操作系统限定的队列的最大长度。值得注意的是，在以下几种情况中，仍然会采用操作系统限定的队列的最大长度：◆backlog参数的值大于操作系统限定的队列的最大长度；◆backlog参数的值小于或等于0；◆在ServerSocket构造方法中没有设置backlog参数。以下例程3-1的Client.java和例程3-2的Server.java用来演示服务器的连接请求队列的特性。例程3-1Client.javaimport java.net.*;public class Client {public static void main(String args[])throws Exception{final int length=100;String host="localhost";int port=8000;Socket[] sockets=new Socket[length];for(int i=0;ijava RandomPort监听的端口为:3000C:chapter03classes>java RandomPort监听的端口为:3004C:chapter03classes>java RandomPort监听的端口为:3005多数服务器会监听固定的端口，这样才便于客户程序访问服务器。匿名端口一般适用于服务器与客户之间的临时通信，通信结束，就断开连接，并且ServerSocket占用的临时端口也被释放。FTP（文件传输）协议就使用了匿名端口。如图3-1所示，FTP协议用于在本地文件系统与远程文件系统之间传送文件。图3-1FTP协议用于在本地文件系统与远程文件系统之间传送文件FTP使用两个并行的TCP连接：一个是控制连接，一个是数据连接。控制连接用于在客户和服务器之间发送控制信息，如用户名和口令、改变远程目录的命令或上传和下载文件的命令。数据连接用于传送文件。TCP服务器在21端口上监听控制连接，如果有客户要求上传或下载文件，就另外建立一个数据连接，通过它来传送文件。数据连接的建立有两种方式。（1）如图3-2所示，TCP服务器在20端口上监听数据连接，TCP客户主动请求建立与该端口的连接。图3-2TCP服务器在20端口上监听数据连接（2）如图3-3所示，首先由TCP客户创建一个监听匿名端口的ServerSocket，再把这个ServerSocket监听的端口号（调用ServerSocket的getLocalPort()方法就能得到端口号）发送给TCP服务器，然后由TCP服务器主动请求建立与客户端的连接。图3-3TCP客户在匿名端口上监听数据连接以上第二种方式就使用了匿名端口，并且是在客户端使用的，用于和服务器建立临时的数据连接。在实际应用中，在服务器端也可以使用匿名端口。3.5ServerSocket选项ServerSocket有以下3个选项。◆SO_TIMEOUT：表示等待客户连接的超时时间。◆SO_REUSEADDR：表示是否允许重用服务器所绑定的地址。◆SO_RCVBUF：表示接收数据的缓冲区的大小。3.5.1SO_TIMEOUT选项◆设置该选项：public void setSoTimeout(int timeout) throws SocketException◆读取该选项：public int getSoTimeout () throws IOExceptionSO_TIMEOUT表示ServerSocket的accept()方法等待客户连接的超时时间，以毫秒为单位。如果SO_TIMEOUT的值为0，表示永远不会超时，这是SO_TIMEOUT的默认值。当服务器执行ServerSocket的accept()方法时，如果连接请求队列为空，服务器就会一直等待，直到接收到了客户连接才从accept()方法返回。如果设定了超时时间，那么当服务器等待的时间超过了超时时间，就会抛出SocketTimeoutException，它是InterruptedException的子类。如例程3-4所示的TimeoutTester把超时时间设为6秒钟。#p#例程3-4TimeoutTester.javaimport java.io.*;import java.net.*;public class TimeoutTester{public static void main(String args[])throws IOException{ServerSocket serverSocket=new ServerSocket(8000);serverSocket.setSoTimeout(6000); //等待客户连接的时间不超过6秒Socket socket=serverSocket.accept();socket.close();System.out.println("服务器关闭");}}运行以上程序，过6秒钟后，程序会从serverSocket.accept()方法中抛出Socket- TimeoutException：C:chapter03classes>java TimeoutTesterException in thread "main" java.net.SocketTimeoutException: Accept timed outat java.net.PlainSocketImpl.socketAccept(Native Method)at java.net.PlainSocketImpl.accept(Unknown Source)at java.net.ServerSocket.implAccept(Unknown Source)at java.net.ServerSocket.accept(Unknown Source)at TimeoutTester.main(TimeoutTester.java:8)如果把程序中的“serverSocket.setSoTimeout(6000)”注释掉，那么serverSocket. accept()方法永远不会超时，它会一直等待下去，直到接收到了客户的连接，才会从accept()方法返回。Tips：服务器执行serverSocket.accept()方法时，等待客户连接的过程也称为阻塞。本书第4章的4.1节（线程阻塞的概念）详细介绍了阻塞的概念。3.5.2SO_REUSEADDR选项◆设置该选项：public void setResuseAddress(boolean on) throws SocketException◆读取该选项：public boolean getResuseAddress() throws SocketException这个选项与Socket的SO_REUSEADDR选项相同，用于决定如果网络上仍然有数据向旧的ServerSocket传输数据，是否允许新的ServerSocket绑定到与旧的ServerSocket同样的端口上。SO_REUSEADDR选项的默认值与操作系统有关，在某些操作系统中，允许重用端口，而在某些操作系统中不允许重用端口。当ServerSocket关闭时，如果网络上还有发送到这个ServerSocket的数据，这个ServerSocket不会立刻释放本地端口，而是会等待一段时间，确保接收到了网络上发送过来的延迟数据，然后再释放端口。许多服务器程序都使用固定的端口。当服务器程序关闭后，有可能它的端口还会被占用一段时间，如果此时立刻在同一个主机上重启服务器程序，由于端口已经被占用，使得服务器程序无法绑定到该端口，服务器启动失败，并抛出BindException：Exception in thread "main" java.net.BindException: Address already in use: JVM_Bind为了确保一个进程关闭了ServerSocket后，即使操作系统还没释放端口，同一个主机上的其他进程还可以立刻重用该端口，可以调用ServerSocket的setResuse- Address(true)方法：if(!serverSocket.getResuseAddress())serverSocket.setResuseAddress(true);值得注意的是，serverSocket.setResuseAddress(true)方法必须在ServerSocket还没有绑定到一个本地端口之前调用，否则执行serverSocket.setResuseAddress(true)方法无效。此外，两个共用同一个端口的进程必须都调用serverSocket.setResuseAddress(true)方法，才能使得一个进程关闭ServerSocket后，另一个进程的ServerSocket还能够立刻重用相同端口。3.5.3SO_RCVBUF选项◆设置该选项：public void setReceiveBufferSize(int size) throws SocketException◆读取该选项：public int getReceiveBufferSize() throws SocketExceptionSO_RCVBUF表示服务器端的用于接收数据的缓冲区的大小，以字节为单位。一般说来，传输大的连续的数据块（基于HTTP或FTP协议的数据传输）可以使用较大的缓冲区，这可以减少传输数据的次数，从而提高传输数据的效率。而对于交互式的通信（Telnet和网络游戏），则应该采用小的缓冲区，确保能及时把小批量的数据发送给对方。SO_RCVBUF的默认值与操作系统有关。例如，在Windows 2000中运行以下代码时，显示SO_RCVBUF的默认值为8192：ServerSocket serverSocket=new ServerSocket(8000);System.out.println(serverSocket.getReceiveBufferSize());//打印8192无论在ServerSocket绑定到特定端口之前或之后，调用setReceiveBufferSize()方法都有效。例外情况下是如果要设置大于64K的缓冲区，则必须在ServerSocket绑定到特定端口之前进行设置才有效。例如，以下代码把缓冲区设为128K：ServerSocket serverSocket=new ServerSocket();int size=serverSocket.getReceiveBufferSize();if(size<131072) serverSocket.setReceiveBufferSize(131072);//把缓冲区的大小设为128KserverSocket.bind(new InetSocketAddress(8000)); //与8 000端口绑定执行serverSocket.setReceiveBufferSize()方法，相当于对所有由serverSocket.accept()方法返回的Socket设置接收数据的缓冲区的大小。3.5.4设定连接时间、延迟和带宽的相对重要性◆public void setPerformancePreferences(int connectionTime,int latency,int bandwidth) 该方法的作用与Socket的setPerformancePreferences()方法的作用相同，用于设定连接时间、延迟和带宽的相对重要性，参见本书第2章的2.5.10节（设定连接时间、延迟和带宽的相对重要性）。
Read Send Connect Error无非就这几种方法啊。

DPDK没有协议栈，两种方式，一种使用第三方有基于DPDK开发的开源的TCP/IP协议栈，另外一种方式将收发报文通过linuxTUN/TAP设备转到linux内核协议栈中处理

意思你需要一个计时工具？ 比较简单的方式是把发送和接收的机器，两个机器时间同步一下。。。这边发送一个数据包，用udp发吧，数据内容就是gettimeofday的结果..那边收到数据，立刻gettimeofday获得一个时间，两个时间差就是传输时间呗...或者等那边回送数据包，回送的内容还是收到的内容，发送端自己在gettimeofday一次，两个时间差除以2就是发送时间了吧...这样就不用同步时间了。。当然最好可以多次统计，比如发一串包，每个数据包内容包含一个编号，一个发出时间，下次收到的时候根据编号以及数据发出时间就得到了中间花费时间，数据取平均值就好了。上面都是我猜测的..没弄过实验.. 还有，tcp就有自己计算时间的方式啊..我忘掉了...叫rtt还是什么的，似乎专门还有个算法，记不得了。。。你查下tcp/ip详解...

服务器端代码: using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Text;using System.Windows.Forms;using System.Threading;using System.Net;using System.Net.Sockets;namespace ChatToolServer{public partial class Form1 : Form{//server-用于处理客户端连接请求的socketSocket clientSocket = null;delegate void del();public Form1(){InitializeComponent();}//server-侦听方法private void listen(){//获取服务器IPstring hostName = Dns.GetHostName();IPAddress[] ip = Dns.GetHostAddresses(hostName);IPAddress HostIp = ip[0];//创建一个网络端点IPEndPoint iep = new IPEndPoint(HostIp, 82);//创建服务端服务端套接字Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//将套接字与网络端点绑定serverSocket.Bind(iep);//将套接字置为侦听状态，并设置最大队列数为10serverSocket.Listen(10);//以同步方式从侦听套接字的连接请求队列中提取第一个挂起的连接请求，然后创建并返回新的 Socket//新的套接字：包含对方计算机的IP和端口号，可使用这个套接字与本机进行通信clientSocket = serverSocket.Accept();if (clientSocket != null){MessageBox.Show("连接成功！");}}private void send_Click(object sender, EventArgs e){if (this.textBox1.Text != "")//不能发送空消息{try{//发送数据string message = textBox1.Text;byte[] sendbytes = System.Text.Encoding.UTF8.GetBytes(message);int successSendBtyes = clientSocket.Send(sendbytes, sendbytes.Length, SocketFlags.None);}catch (Exception exp){MessageBox.Show(exp.Message);}//将发送的数据显示到对话窗口并使对话窗口的滚动条一直停留在最下方this.textBox2.Text +="服务器:"+"rn" +textBox1.Text + "rn";//发完一条消息就换行显示this.textBox2.SelectionStart = this.textBox2.Text.Length;this.textBox2.ScrollToCaret();this.textBox1.Text = "";//将发送窗口清空}else{MessageBox.Show("发送内容不能为空");}}private void Form1_Load(object sender, EventArgs e){//server-创建并运行侦听线程Thread threadListen = new Thread(new ThreadStart(listen));threadListen.Start();}private void timer1_Tick(object sender, EventArgs e){byte[] receiveBytes = new byte[1024];//如果侦听后取得客户端连接，并且客户端的缓冲区中有内容可读,开始接收数据if (clientSocket != null){if (clientSocket.Poll(100, SelectMode.SelectRead)){int successReceiveBytes = clientSocket.Receive(receiveBytes);this.textBox2.Text += "客户端:" +"("+ clientSocket.RemoteEndPoint.ToString()+")"+"rn" +System.Text.Encoding.UTF8.GetString(receiveBytes, 0, successReceiveBytes) + "rn";this.textBox2.SelectionStart = this.textBox2.Text.Length;//使对话窗口的滚动条一直停留在最下方this.textBox2.ScrollToCaret();}}}}}客户端代码;using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Text;using System.Windows.Forms;using System.Net;using System.Net.Sockets;using System.Threading;namespace ChatToolClient{public partial class Form1 : Form{Socket clientSocket = null;//客户端套接字public Form1(){InitializeComponent();}private void Form1_Load(object sender, EventArgs e){try{//建立与服务器连接的套接字IPAddress ip = IPAddress.Parse("172.16.94.134");IPEndPoint iep = new IPEndPoint(ip, 82);clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);clientSocket.Connect(iep);textBox2.Text = "连接成功" + "rn";}catch (Exception exp){MessageBox.Show(exp.Message);}}private void send_Click(object sender, EventArgs e){if (textBox1.Text != ""){try{//发送数据string message = textBox1.Text;byte[] sendbytes = System.Text.Encoding.UTF8.GetBytes(message);int successSendBtyes = clientSocket.Send(sendbytes, sendbytes.Length, SocketFlags.None);}catch (Exception exp){MessageBox.Show(exp.Message);}//将发送的数据显示到对话窗口并使对话窗口的滚动条一直停留在最下方this.textBox2.Text += "我自己:"+"rn"+textBox1.Text + "rn";//发完一条消自己息就换行显示this.textBox2.SelectionStart = this.textBox2.Text.Length;this.textBox2.ScrollToCaret();this.textBox1.Text = "";//将发送窗口清空}else{MessageBox.Show("发送内容不能为空");}}private void timer1_Tick(object sender, EventArgs e){byte[] receiveBytes = new byte[1024];if (clientSocket.Poll(100, SelectMode.SelectRead)){int successReceiveBytes = clientSocket.Receive(receiveBytes);this.textBox2.Text +="服务器:"+"rn"+System.Text.Encoding.UTF8.GetString(receiveBytes, 0, successReceiveBytes) + "rn";this.textBox2.SelectionStart = this.textBox2.Text.Length;//使对话窗口的滚动条一直停留在最下方this.textBox2.ScrollToCaret();}}}} 另外,本人有很多自己写的Socket代码,包括TCP,UDP.并且同步,异步方法的都有.阁下需要的话,可以联系本人. E-mail:pjw216@126.com
推荐：Sybex - Csharp Network Programming 这本书。 Socket编程一直是最统一的领域，windows下和linux都大同小异。因此你可以看看winsock的编程资料。