知识大全 Java中的TCP/UDP网络通信编程

Posted 2022-07-19 知

篇首语：生活的理想，就是为了理想的生活本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Java中的TCP/UDP网络通信编程相关的知识，希望对你有一定的参考价值。

Java中的TCP/UDP网络通信编程 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　是回路地址用于测试相当于localhost本机地址没有网卡不设DNS都可以访问

　　端口地址在 ~ 之间其中 ~ 之间的端口是用于一些知名的网络服务和应用用户的普通网络应用程序应该使用以上的端口

　　网络应用中基本上都是TCP(Transmission Control Protocol传输控制协议)和UDP(User Datagram Protocol用户数据报协议) TCP是面向连接的通信协议 UDP是无连接的通信协议

　　Socket连接套接字 Java分别为TCP和UDP提供了相应的类 TCP是 ServerSocket(用于服务器端)和 Socket(用于客户端);UDP是 DatagramSocket

　　 Java编写UDP网络程序

　　 DatagramSocket

　　DatagramSocket有如下构造方法:

　　 DatagramSocket() :构造数据报套接字并将其绑定到本地主机上任何可用的端口

　　 DatagramSocket(int port):创建数据报套接字并将其绑定到本地主机上的指定端口

　　 DatagramSocket(int port InetAddress laddr):创建数据报套接字将其绑定到指定的本地地址即指定网卡发送和接收数据

　　如果在创建DatagramSocket对象时没有指定网卡的IP 地址在发送数据时底层驱动程序会自动选择一块网卡去发送在接收数据时会接收所有的网卡收到的与端口一致的数据

　　发送信息时可以不指定端口号接收信息时要指定端口号因为要接收指定的数据

　　发送数据使用DatagramSocket send(DatagramPacket p)方法接收数据使用DatagramSocket receive(DatagramPacket p)方法

　　 DatagramPacket

　　DatagramPacket类有如下构造方法:

　　 DatagramPacket(byte[] buf int length):构造 DatagramPacket 用来接收长度为length的数据包

　　 DatagramPacket(byte[] buf int length InetAddress address int port):构造数据报包用来将长度为length的包发送到指定主机上的指定端口号

　　接收数据时使用第一次构造方法发送数据时使用第二种构造方法

　　 InetAddress

　　Java中对IP地址进行包装的类

　　DatagramPacket getAddress()可以获取发送或接收方的IP地址 DatagramPacket getPort()可以获取发送或接收方的端口

　　 UDP程序例子

　　发送程序:

　　import DatagramPacket;

　　import DatagramSocket;

　　import InetAddress;

　　public class UdpSend

　　public static void main(String[] args) throws Exception

　　DatagramSocket ds = new DatagramSocket();

　　String str = hello world! ;

　　DatagramPacket dp = new DatagramPacket(str getBytes() str length() InetAddress getByName( ) );

　　ds send(dp);

　　ds close(); //关闭连接

　　接收程序:

　　import DatagramPacket;

　　import DatagramSocket;

　　public class UdpRecv

　　public static void main(String[] args) throws Exception

　　DatagramSocket ds = new DatagramSocket( );

　　byte[] buf = new byte[ ];

　　DatagramPacket dp = new DatagramPacket(buf buf length);

　　ds receive(dp);

　　String str = new String(dp getData() dp getLength());

　　System out println(str);

　　System out println( IP: + dp getAddress() getHostAddress() + PORT: + dp getPort());

　　ds close();

　　测试要先运行接收程序再运行发送程序如果接收程序没有接收到数据则会一直阻塞接收到数据后才会关闭程序如果网络上没有数据发送过来接收程序也没有阻塞通常都是使用了一个已经被占用的端口

　　 Java编写TCP网络程序

　　 ServerSocket

　　编写TCP网络服务程序首先要用到 ServerSocket类用以创建服务器Socket 它的常用构造方法有:

　　 ServerSocket(int port):创建绑定到特定端口的服务器套接字

　　 ServerSocket(int port int backlog):利用指定的backlog(服务器忙时保持连接请求的等待客户数量) 创建服务器套接字并将其绑定到指定的本地端口号

　　 ServerSocket(int port int backlog InetAddress bindAddr):使用指定的端口侦听 backlog 和要绑定到的本地 IP 地址创建服务器

　　 Socket

　　客户端要与服务器建立连接必须先创建一个Socket对象它的常用构造方法有:

　　 Socket(String host int port):创建一个流套接字并将其连接到指定主机上的指定端口号

　　 Socket(InetAddress address int port):创建一个流套接字并将其连接到指定 IP 地址的指定端口号

　　 Socket(InetAddress address int port InetAddress localAddr int localPort):创建一个套接字并将其连接到指定远程端口上的指定远程地址

　　 Socket(String host int port InetAddress localAddr int localPort):创建一个套接字并将其连接到指定远程主机上的指定远程端口

　　对于通常情况的应用使用第个构造方法来创建客户端的Socket对象并与服务器建立连接是非常简单和方便的

　　服务器端程序调用ServerSocket accept方法等待客户端的连接请求一旦accept接收了客户端连接请求该方法返回一个与该客户端建立了专线连接的Socket对象不用程序去创建这个Socket对象建立了连接的两个Socket是以IO流的方式进行数据交换的 Java提供了Socket getInputStream返回Socket的输入流对象 Socket getOutputStream返回Socket的输出流对象

　　 TCP程序例子的服务器程序:

　　import java io InputStream;

　　import java io OutputStream;

　　import ServerSocket;

　　import Socket;

　　public class TcpServer

　　public static void main(String[] args) throws Exception

　　ServerSocket ss = new ServerSocket( );

　　Socket s = ss accept();

　　InputStream ips = s getInputStream();

　　OutputStream ops = s getOutputStream();

　　ops write( hello World! getBytes());

　　byte[] buf = new byte[ ];

　　int len = ips read(buf);

　　System out println(new String(buf len));

　　ips close();

　　ops close();

　　s close();

　　ss close();

　　在这个程序里创建了一个在端口上等待连接的ServerSocket对象当接收到一个客户的连接请求后程序从与这个客户建立了连接的Socket对象中获得输入输出流对象通过输出流首先向客户端发送一串字符然后通过输入流读取客户端发送过来的信息并将这些信息打印然后关闭所有资源

　　要先运行服务器程序然后才能运行客户端程序当TCP服务器程序运行到Socket accpet()方法等待客户连接时 accept方法将阻塞一直到有客户连接请求到来该方法才会返回如果又没有请求到来又没有发生阻塞通常都是使用了一个已经被占用的端口

　　我们可以使用windows提供的telnet工具在命令行窗口中测试一下服务器程序:命令如下:telnet localhost

　　可以看到 telnet只要有输入就发送因此我们如果想要在服务器端一次读多个字符的话还需要进一步处理看如下代码:

　　import java io BufferedReader;

　　import java io InputStream;

　　import java io InputStreamReader;

　　import java io OutputStream;

　　import ServerSocket;

　　import Socket;

　　public class TcpServer

　　public static void main(String[] args) throws Exception

　　ServerSocket ss = new ServerSocket( );

　　Socket s = ss accept();

　　InputStream ips = s getInputStream();

　　BufferedReader br = new BufferedReader(new InputStreamReader(ips)); //对InputStream进行包装增加了缓存

　　OutputStream ops = s getOutputStream();

　　ops write( hello World! getBytes());

　　System out println(br readLine());

　　br close(); //关闭包装类会自动关闭里面的基类

　　ops close();

　　s close();

　　ss close();

　　再次使用telnet工具可以看到这次可以发送不止一个字符了按回车键后发送数据到服务器端

　　 TCP程序例子改进后的服务器程序:

　　大多数情况下服务器端都要服务多个客户端但一次accept方法调用只接收一个连接因此要把accept方法放在一个循环语句中这样就可以接收多个连接每个连接的数据交换代码也放在一个循环中这样才能保证两者可以不停地交换数据

　　每个连接的数据交换代码必须放在独立的线程中运行否则这在段代码运行期间就没法执行其他的程序代码 accept方法也得不到调用新的连接无法进入

　　下面是一个例子客户端向服务器发送一个字符串服务器将这个字符串中的所有字符反向排列后回送给客户端客户端输入 quit 退出程序

　　import java io BufferedReader;

　　import java io DataOutputStream;

　　import java io InputStream;

　　import java io InputStreamReader;

　　import java io OutputStream;

　　import ServerSocket;

　　import Socket;

　　public class TcpServer

　　public static void main(String[] args) throws Exception

　　ServerSocket ss = new ServerSocket( );

　　while(true)

　　Socket s = ss accept();

　　new Thread(new Servicer(s)) start();

　　class Servicer implements Runnable

　　Socket s;

　　public Servicer(Socket s)

　　this s = s;

　　public void run()

　　try

　　InputStream ips = s getInputStream();

　　OutputStream ops = s getOutputStream();

　　BufferedReader br = new BufferedReader(new InputStreamReader(ips));

　　DataOutputStream dos = new DataOutputStream(ops);

　　while(true)

　　String strWord = br readLine();

　　if(strWord equalsIgnoreCase( quit ))

　　break;

　　String strEcho = (new StringBuffer(strWord) reverse() toString());

　　dos writeBytes(strWord + > + strEcho + System getProperty( line separator ));

　　br close();

　　dos close();

　　s close();

　　catch(Exception e)

　　e printStackTrace();

　　 TCP程序例子客户端程序:

　　import java io BufferedReader;

　　import java io DataOutputStream;

　　import java io InputStream;

　　import java io InputStreamReader;

　　import java io OutputStream;

　　import InetAddress;

　　import Socket;

　　public class TcpClient

　　public static void main(String[] args) throws Exception

　　if(args length < )

　　System out println( Usage:java TcpClient ServerIP ServerPort );

　　return ;

　　Socket s = new Socket(InetAddress getByName(args[ ]) Integer parseInt(args[ ]));

　　InputStream ips = s getInputStream();

　　OutputStream ops = s getOutputStream();

　　BufferedReader brKey = new BufferedReader(new InputStreamReader(System in));

　　DataOutputStream dos = new DataOutputStream(ops);

　　BufferedReader brNet = new BufferedReader(new InputStreamReader(ips));

　　while(true)

　　String strWord = brKey readLine();

　　dos writeBytes(strWord + System getProperty( line separator ));

　　if( quit equalsIgnoreCase(strWord))

　　break;

　　else

　　System out println(brNet readLine());

　　dos close();

　　brNet close();

　　brKey close();

　　s close();

　　先运行服务器程序再在命令行使用java TcpClient 这样就启动了客户端程序我们可以启动多个客户端程序

cha138/Article/program/Java/hx/201311/26522