开发者社区> 灰小猿> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

Java利用TCP协议实现客户端与服务器通信【附通信源码】

简介:
+关注继续查看

 

进行TCP协议网络程序的编写,关键在于ServerSocket套接字的熟练使用,TCP通信中所有的信息传输都是依托ServerSocket类的输入输出流进行的。

目录

TCP协议概念

ServerSocket类

服务器端程序

客户端程序


Hello!大家好哇!我是灰小猿!

上一篇博客和大家分享了在网络编程中要注意的基础知识,关于IP、TCP、UDP以及端口和套接字的一些概念,想了解的小伙伴可以看我的这篇文章“盘点那些进行网络编程必须要知道的基础知识”,那么今天大灰狼就来和大家分享一下如何使用TCP/IP进行网络程序的开发。

TCP协议概念

先来了解一下TCP协议的基本概念。

我们知道TCP是可靠而非安全的网络协议。它可以保证数据在从一端送至另一端的时候可以准确的送达,并且抵达的数据的排列顺序和送出时的顺序是相同的。因此在进行TCP协议通信的时候,我们首先应该保证客户端和服务器之间的连接通畅。

而TCP协议程序的编写,仍然是依靠套接字Socket类来实现的,并且利用TCP协议进行通信的两个程序之间是有主次之分的,即一个是服务器的程序,另一个是客户端的程序。因此两者的功能和编写上也略有不同。如下图是服务器与客户端之间进行通信的示意图:

imageimage.gif编辑

以上就是在TCP协议中客户端与服务器建立连接的过程示意图。而在这其中起到关键作用的就是服务器端套接字ServerSocket和客户端套接字Socket。通过这两个套接字来建立服务器和客户端,从而利用其中的函数进行数据的通信。

在ServerSocket类中有很多需要注意的地方,接下来大灰狼和大家分享一下ServerSocket类的具体用法:

ServerSocket类

ServerSocket类存在于Java.net包中,表示服务器端的套接字,在使用时需要首先导入这个类,我们也知道ServerSocket类的主要功能就是通过指定的端口等待来自于网络中客户端的请求并且进行连接。

值得注意的是:服务器套接字一次只能与一个客户端套接字进行连接,因此如果存在多台客户端同时发送连接请求,则服务器套接字就会将请求的客户端存放到队列中去,然后从中取出一个套接字与服务器建立的套接字进行连接,但是服务器端能够容纳的客户端套接字也不是无限的,当请求连接的数量大于最大容纳量时,那么多出来的请求就会被拒接,一般来说队列的默认大小是50。

ServerSocket类的构造方法通常会抛出IOException异常,具体有以下几种形式:

    • ServerSocket():创建非绑定服务器套接字
    • ServerSocket(inr port):创建绑定到特定端口的服务器套接字
    • ServerSocket(int port, int backlog):利用指定的backlog创建服务器套接字,并将其绑定到指定的服务器端口上,
    • ServerSocket(int port, int backlog, InetAddress bindAddress):使用指定的端口,侦听backlog和要绑定到本地的IP地址创建服务器。这种情况适用于计算机上有多个网卡和多个IP地址的情况,用户可以明确的规定ServerSocket在哪块网卡或哪个IP地址上等待用户的连接请求。

    以下是ServerSocket类中一些常用的方法:

    ServerSocket类中常用的方法

    方法

    返回值说明
    accept()Socket等待客户机连接,若连接则创建一个客户端套接字
    isBound()boolean判断ServerSocket的绑定状态
    getInetAddress()InetAddress返回此服务器套接字的本地地址
    isClosed()boolean返回服务器套接字的关闭状态
    close()void关闭服务器套接字
    bind(SocketAddress endpoint)void将ServerSocket绑定到特定地址(IP地址和端口号)
    getInetAddress()int返回服务器套接字等待的端口号

    了解了ServerSocket类的基本方法之后,就是如何进行客户端和服务器进行连接的问题了。

    在服务器端我们可以调用ServerSocket类的accpet()方法与请求连接的客户机建立连接,这时会返回一个和客户端相连接的Socket对象,这个时候其实已经连接成功了,使用getInetAddress()方法就可以获取到进行请求的客户机的IP地址。

    对于如何进行客户端和服务器端数据的通信,就要用到数据的输入流和输出流了,服务器端的Socket对象使用getOutputStream()方法获取到的输出流,将指向客户端的Socket对象使用getInputStream()方法获取到的输入流。由此就实现在服务器向客户端发送数据的一个过程,同样的道理,客户端端的Socket对象使用getOutputStream()方法获取到的输出流,将指向服务器端的Socket对象使用getInputStream()方法获取到的输入流。从而实现由客户端向服务器发送数据的过程。

    注意:accpet()方法会阻塞线程的继续执行,如果在对应的接口没有收到客户端的呼叫,则程序会停留在此处,直到获取到客户端的呼叫才会继续向下执行,但是如果服务器没有收到来自客户端的呼叫请求,并且accpet()方法没有发生阻塞,那么通常情况下就是程序出了问题,一般来说可能是使用了一个已经被其他程序占用了的端口号,导致ServerSocket没有绑定成功!遇到这种情况可以尝试更换新的端口号。

    了解了TCP协议的通信过程,接下来就是进行TCP通信程序的书写啦!

    在网络通信中,如果只要求客户机向服务器发送信息,不要求服务器向客户端反馈信息的行为称为“单向通信”,要求客户机和服务器双方互相通信的过程称为“双向通信”,双向通信只不过是比单向通信多了一个服务器向客户端发送消息的过程,

    接下来分别是服务器端和客户端程序的编写:

    服务器端程序

    package server_1;
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    public class MyTcp {
        private ServerSocket server;    //设置服务器套接字
        private Socket client;      //设置客户端套接字
        
        //连接客户端函数
        void getServer()
        {
            try {
                server = new ServerSocket(1100);    //建立服务器 端口为1100
                System.out.println("服务器建立成功!正在等待连接......");
                client = server.accept();   //调用服务器函数对客户端进行连接           
                System.out.println("客户端连接成功!ip为:" + client.getInetAddress());   //返回客户端IP       
                getClientMessage();     //调用信息传输和接收函数
                
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
        
        void getClientMessage()
        {
            try {
                while (true) {
                    InputStream is = client.getInputStream();   //获取到客户端的输入流
                    byte[] b = new byte[1024];  //定义字节数组
                    int len = is.read(b);   //由于信息的传输是以二进制的形式,所以要以二进制的形式进行数据的读取
                    String data = new String(b, 0,len);
                    System.out.println("客户端发来消息:" + data);
                    
                    //定义发送给客户端的输出流
                    OutputStream put = client.getOutputStream();
                    String putText = "我已经收到!欢迎你!";
                    put.write(putText.getBytes());  //将输出流信息以二进制的形式进行写入
                }
            } catch (Exception e) {
                // TODO: handle exception
            }
            try {
                //判断客户端字节流不是空,则关闭客户端
                if (server != null) {
                    server.close();
                }
            } catch (Exception e) {
                // TODO: handle exception
            }
        }
        
        public static void main(String[] args) {
            // TODO Auto-generated method stub
            MyTcp myTcp = new MyTcp();  //调用该类生成对象
            myTcp.getServer();  //调用方法
        }
    }

    image.gif

    客户端程序

    package client_1;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintWriter;
    import java.net.Socket;
    import java.net.UnknownHostException;
    public class MyClient {
        private Socket client;  //定义客户端套接字
        
        //建立客户端函数
        void getClient()
        {
            try {
                client = new Socket("127.0.0.1", 1100); //建立客户端,使用的IP为127.0.0.1,端口和服务器一样为1100
                System.out.println("客户端建立成功!");
                
                setClientMessage();     //调用客户端信息写入函数
            } catch (UnknownHostException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
        //定义客户端信息写入函数
        void setClientMessage()
        {
            try {       
                OutputStream pt = client.getOutputStream();     //建立客户端信息输出流
                String printText = "服务器你好!我是客户端!";  
                pt.write(printText.getBytes());     //以二进制的形式将信息进行输出
                
                InputStream input = client.getInputStream();    //建立客户端信息输入流
                byte [] b = new byte[1024];     //定义字节数组
                int len = input.read(b);    //读取接收的二进制信息流
                String data = new String(b, 0,len);
                System.out.println("收到服务器消息:" + data);
                
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            try {
                //如果客户端信息流不为空,则说明客户端已经建立连接,关闭客户端
                if (client != null) {
                    client.close();
                }
            } catch (Exception e) {
                // TODO: handle exception
            }
        }
        
        public static void main(String[] args) {
            // TODO Auto-generated method stub
            //生成客户端类对象
            MyClient myClient  = new MyClient();
            myClient.getClient();
        }
    }

    image.gif

    同时要注意:在客户端和服务器搭建成功之后,应该先打开服务器等待连接,再打开客户端进行连接,同样在进行关闭时,应该先关闭客户端,再关闭服务器。

    以上面程序为例:

    打开服务器等待客户端连接

    imageimage.gif编辑

    打开客户端与服务器连接成功,并且实现双向通信:

    imageimage.gif编辑

    注意:当一台机器上安装了多个网络应用程序时,很可能指定的端口已经被占用,甚至还可能遇到之前运行很好的程序突然卡住的情况,这种情况很可能是端口被别的程序占用了,这时可以运行netstat-help来活的帮助,可以使用命令netstat-an来查看该程序所使用的端口。

    觉得有用记得点赞关注哟!

    灰小猿期待与你一同进步^ω^

    imageimage.gif编辑

    版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

    相关文章
    本机Linux子系统Ubuntu免密登陆远程服务器同时实现多用户免密登陆服务器
    本机Linux子系统Ubuntu免密登陆远程服务器同时实现多用户免密登陆服务器
    194 0
    CentOS 将于年底终止!Linux服务器该何去何从?
    CentOS 将于年底终止!Linux服务器该何去何从?
    277 0
    【运维】Linux 服务器 基本安防配置
    【运维】Linux 服务器 基本安防配置
    42 0
    宝塔一键部署项目及Linux服务器三种软件安装方式【JDK、Tmcat、Docker】
    宝塔一键部署项目及Linux服务器三种软件安装方式【JDK、Tmcat、Docker】
    279 0
    Linux服务器被入侵向外发包的处理解决方法
    下面通过Sinesafe的客户一个案例介绍下当一个服务器被rootkit入侵后的处理思路和处理过程,rootkit攻击是Linux系统下最常见的攻击手段和攻击方式。
    429 0
    Linux系统开发: 搭建NFS服务器实现文件共享
    Linux系统开发: 搭建NFS服务器实现文件共享
    82 0
    【精通Linux系列】服务器之间的telnet与scp命令用法,进程管理命令之ps -ef与ps aux详解
    【精通Linux系列】服务器之间的telnet与scp命令用法,进程管理命令之ps -ef与ps aux详解
    81 0
    Linux服务器被黑,该怎么处理解决
    很多客户网站服务器被入侵,被攻击,找到我们SINE安全公司寻求技术支持与帮助,有些网站被篡改,被跳转,首页内容被替换,服务器植入木马后门,服务器卡顿,服务器异常网络连接,有的客户使用的是阿里云服务器,经常被提醒服务器有挖矿程序,以及网站被上传webshell的安全提醒,包括腾讯云提示服务器有木马文件,客户网站被攻击的第一时间,是需要立即处理的,降损失降到最低,让网站恢复正常的访问,由于每个客户找到我们SINE安全都是比较着急的,安全的处理时间也需要尽快的处理,根据我们的处理经验,我们总结了一些服务器被攻击,被黑的排查办法,专门用来检查服务器第一时间的安全问题,看发生在哪里,服务器是否被黑,是否
    126 0
    【精通Linux系列】CentOS7 实战部署tomcat网站服务器
    【精通Linux系列】CentOS7 实战部署tomcat网站服务器
    51 0
    Linux 服务器必备的安全设置,建议收藏!
    Linux 服务器必备的安全设置,建议收藏!
    39 0
    +关注
    灰小猿
    一个用代码编织世界的工程师
    文章
    问答
    文章排行榜
    最热
    最新
    相关电子书
    更多
    面向多端的AliOS开放策略
    立即下载
    Jpom一款低侵入式Java运维、监控软件
    立即下载
    阿里云MongoDB备份恢复功能说明和原理介绍
    立即下载