JAVA网络编程TCP通信

本文主要是介绍JAVA网络编程TCP通信，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

Socket简介：

Socket称为“套接字”，描述IP地址和端口。在Internet上的主机一般运行多个服务软件，同时提供几种服务，每种服务都打开一个Socket,并绑定在一个端口上，不同的端口对应于不同的服务。Socket和ServerSocket类位于java.net包中。ServerSocket用于服务端，Socket是建立网络连接时使用的。连接成功时，应用程序两端都会产生一个Socket实例，通过操作这个实例完成所需会话。

Socket常用方法：

-int getLocalPort() 获取本地使用的端口号

-InetAddress getLocalAddress() 获取套接字绑定的本地地址

-int getPort() 获取远端使用的端口号

-InetAddress.getInetAddress() 获取套接字绑定的远端地址

InetAddress常用方法：

-String getCanonicalHostName() 获取此IP地址的完全限定域名。

-String getHostAddress() 返回IP地址字符串

1 //获取本地地址和端口号：2 　　public void testSocket() throws Exception{3     　　Socket socket=new Socket("localhost",8088);4     　　InetAddress add=socket.getLocalAddress();5     　　System.out.println(add.getCanonicalHostName());6     　　System.out.println(add.getHostName());7     　　System.out.println(add.getLocalPort());8　　 }

1 //获取远端地址和端口号：2     public static void testSocket() throws Exception{3         Socket socket=new Socket("localhost",8088);4         InetAddress inetAdd=socket.getInetAddress();5         System.out.println(inetAdd.getCanonicalHostName());6         System.out.println(inetAdd.getHostName());7         System.out.println(socket.getLocalPort());8     }

其他方法的使用：

package com.demo.inet;import java.net.InetAddress;import java.net.UnknownHostException;import java.util.Arrays;public class InetAddressDemo {    public static void main(String[] args) {        // 创建一个字节数组byte 127 ~ -128
        byte bt[] = {-64,-88,3,44};//192.168.3.44
        
        try {            // 创建InetAddress对象
            InetAddress id = InetAddress.getByAddress(bt);
            System.out.println(id);            // 返回原始IP地址
            byte[] bs = id.getAddress();
            System.out.println(Arrays.toString(bs));            // 返回对象对应IP地址            System.out.println(id.getHostAddress());            // 返回全名计算名称
            System.out.println(id.getCanonicalHostName()+"------------------");            
            // 返回本机计算机名及对应ip地址            System.out.println(InetAddress.getLocalHost());            
            // 返回host名称对应域名及ip地址
            InetAddress[] allByName = InetAddress.getAllByName("www.baidu.com");
            System.out.println(Arrays.toString(allByName));
            System.out.println(allByName[0].getHostName()); // 域名
            System.out.println(allByName[0].getHostAddress()); // ip地址            
            // 同主机名称获取IP信息
            InetAddress addr = InetAddress.getByName("localhost");
            System.out.println(addr.getHostAddress());
            System.out.println(addr.getCanonicalHostName()); // 返回ip地址
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }
}

获取网络输入流和网络输出流

通过Socket获取输入流与输出流，主要使用一下两个方法

-InputStream getInputStream() 用于返回此套接字的输入流

-OutStream getOutputStream() 用于返回此套接字的输出流

public static void testSocket() throws Exception {
        Socket socket = new Socket("localhost", 8088);
        OutputStream out = socket.getOutputStream();
        OutputStreamWriter osw = new OutputStreamWriter(out, "UTF-8");
        PrintWriter pw = new PrintWriter(osw, true);
        pw.println("输出的内容");//发送内容
        InputStream in=socket.getInputStream();
        InputStreamReader isr=new InputStreamReader(in, "UTF-8");
        BufferedReader br=new BufferedReader(isr);
        br.readLine();//读取接到的内容
 }

注意：当使用完Socket进行通讯完毕后，要关闭Socket以释放系统资源

-void close() 关闭套接字，同时也代表关闭了获取的输入与输出流。

服务端ServerSocket监听

1 //创建ServerSocket并申请服务端口80882 ServerSocket server=new ServerSocket(8088);3 /*方法会产生阻塞，直到某个Socket连接，并返回请求连接的Socket*/4 Socket socket=server.accept();5 ...

客户端Socket连接

1 //参数1：服务端的IP地址，参数2：服务端的服务器端口2 //注意：创建Socket的同时就会发起连接，若连接失败会抛出异常3 Socket socket=new Socket("localhost",8088);4 ....

C-S端通信模型

详细实例演示

Server:

package com.demo.server;import java.io.BufferedOutputStream;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;public class Server {    static int port = 12345;    public static void main(String[] args) {        // 创建服务端Socket对象
        ServerSocket serverSocket = null;        while (true) {            try {                // 创建服务端Socket对象
                serverSocket = new ServerSocket(port);
                System.out.println("等待客户端连接服务器.......");                // 阻塞服务器
                Socket socket = serverSocket.accept();
                System.out.println("客户端连接到服务器.......");                // 创建文件输出流
                BufferedOutputStream os = new BufferedOutputStream(socket.getOutputStream());
                os.write("服务器端: 我收到了客户端连接请求。".getBytes());
                os.flush();
                os.close();

            } catch (Exception e) {
                e.printStackTrace();
            } finally {                try {                    if (serverSocket != null) {
                        serverSocket.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

}

Client:

package com.demo.client;import java.io.BufferedInputStream;import java.io.IOException;import java.net.Socket;public class Client {    static int port = 12345;    static String host = "111.231.93.134";    public static void main(String[] args) {        // 创建客户端对象
        Socket socket = null;        try {            // 创建客户端对象
            socket = new Socket(host, port);            
            // 获取输入流对象
            BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());            // 定义缓冲字节数组
            byte[] buffer = new byte[1024];            // 定义接收实际长度
            int len = 0;            while ((len = bis.read(buffer)) != -1) {
                String content = new String(buffer, 0, len);
                System.out.println("客户端接收的内容:"+content);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {            try {                if (socket != null) {
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

TCP与UDP的区别

TCP（Transmission Control Protocol，传输控制协议）是基于连接的协议，也就是说，在正式收发数据前，必须和对方建立可靠的连接。聊天工具使用TCP协议

UDP（User Data Protocol，用户数据报协议）是与TCP相对应的协议。它是面向非连接的协议，它不与对方建立连接，而是直接就把数据包发送过去！ 游戏多使用UDP协议

UDP程序演示：

Server:

import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress; 
/*
 * 服务器端，实现基于UDP的用户登陆 */public class UDPServer {    public static void main(String[] args) throws IOException {        /*
         * 接收客户端发送的数据         */
        // 1.创建服务器端DatagramSocket，指定端口
        DatagramSocket socket = new DatagramSocket(8800);        // 2.创建数据报，用于接收客户端发送的数据
        byte[] data = new byte[1024];// 创建字节数组，指定接收的数据包的大小
        DatagramPacket packet = new DatagramPacket(data, data.length);        // 3.接收客户端发送的数据
        System.out.println("****服务器端已经启动，等待客户端发送数据");
        socket.receive(packet);// 此方法在接收到数据报之前会一直阻塞        // 4.读取数据
        String info = new String(data, 0, packet.getLength());
        System.out.println("我是服务器，客户端说：" + info); 
        /*
         * 向客户端响应数据         */
        // 1.定义客户端的地址、端口号、数据
        InetAddress address = packet.getAddress();        int port = packet.getPort();        byte[] data2 = "欢迎您!".getBytes();        // 2.创建数据报，包含响应的数据信息
        DatagramPacket packet2 = new DatagramPacket(data2, data2.length, address, port);        // 3.响应客户端        socket.send(packet2);        // 4.关闭资源        socket.close();
    }
}

Client:

import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress; 
/*
 * 客户端 */public class UDPClient {    public static void main(String[] args) throws IOException {        /*
         * 向服务器端发送数据         */
        // 1.定义服务器的地址、端口号、数据
        InetAddress address = InetAddress.getByName("localhost");        int port = 8800;        byte[] data = "用户名：admin;密码：123".getBytes();        // 2.创建数据报，包含发送的数据信息
        DatagramPacket packet = new DatagramPacket(data, data.length, address, port);        // 3.创建DatagramSocket对象
        DatagramSocket socket = new DatagramSocket();        // 4.向服务器端发送数据报        socket.send(packet); 
        /*
         * 接收服务器端响应的数据         */
        // 1.创建数据报，用于接收服务器端响应的数据
        byte[] data2 = new byte[1024];
        DatagramPacket packet2 = new DatagramPacket(data2, data2.length);        // 2.接收服务器响应的数据        socket.receive(packet2);        // 3.读取数据
        String reply = new String(data2, 0, packet2.getLength());
        System.out.println("我是客户端，服务器说：" + reply);        // 4.关闭资源        socket.close();
    }
}

这篇关于JAVA网络编程TCP通信的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！