使用Java编写TCP协议发送和接收数据接口

摘要:
PublicclassFileServerDemo{publicstaticvoidmain(String[]args)throwsIOException{//创建服务器对象ServerSockets=newServerSocket(8080);//侦听客户端连接Sockets=ss.accept();

TCP协议接收数据的步骤:

A:创建接收数据的Socket对象

  创建对象的时候要指定端口

B:监听客户端连接

    等待客户端连接

C:获取Socket对象的输入流(字节流)

D:读数据,并显示在控制台

E:释放资源

服务器:

public class FileServerDemo {

    public static void main(String[] args) throws IOException {
        //创建服务器对象
        ServerSocket ss = new ServerSocket(8080);
        //监听客户端连接
        Socket s = ss.accept();
        //包装通道内的输入流
        BufferedInputStream bis = new BufferedInputStream(
                s.getInputStream());
        //把数据写入文件
        BufferedOutputStream bos = new BufferedOutputStream(
                new FileOutputStream("C:\Users\MA\Desktop\IOtest\copy.jpg"));
        byte[] bys = new byte[1024];
        int len = 0;
        while((len = bis.read(bys))!=-1){
            bos.write(bys,0,len);
        }
        //把通道内的输出流包装
        BufferedWriter write = new BufferedWriter(new OutputStreamWriter(
                s.getOutputStream()));
        write.write("文件上传成功");
        write.newLine();
        write.flush();
        //释放资源
        bos.close();
        s.close();
        ss.close();
    }
}

TCP协议发送数据的步骤:

A:创建发送数据的Socket对象

  创建对象的时候要指定主机和端口

B:获取Socket对象的输出流(字节流)

C:写数据

D:释放资源

客户端:

public class FileClientDemo {

    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket("172.24.60.182",8080);
        //读取文件的数据
        BufferedInputStream bis = new BufferedInputStream(new FileInputStream("C:\Users\MA\Desktop\电路指导书\QQ图片20180627212519.jpg"));
        //把通道内的输出流包装
        BufferedOutputStream bos = new BufferedOutputStream(s.getOutputStream());
        byte[] bys = new byte[1024];
        int len = 0;
        while((len=bis.read(bys))!=-1){
            bos.write(bys,0,len);
        }
        //给服务器一个反馈
        s.shutdownOutput();//禁用输出流
        //获取服务器的反馈信息
        BufferedReader reader = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String data = reader.readLine();
        System.out.println("client:"+data);
        bis.close();
        s.close();
    }
}

转载于:https://www.cnblogs.com/mxj961116/p/9348732.html

免责声明:文章转载自《使用Java编写TCP协议发送和接收数据接口》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇为DataGrid添加自动编号功能R绘图 第七篇:绘制条形图(ggplot2)下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

C#设计模式——代理模式

一、代理模式介绍: 在软件开发过程中,如果直接访问对象给系统带来不必要的复杂性,而且有时候有些对象会由于网络或其他的障碍,以至于不能够或者不能直接访问到这些对象,这时候可以在客户端和目标对象之间增加一层中间层,让代理对象代替目标对象,然后客户端只需要访问代理对象,由代理对象去帮我们去请求目标对象并返回结果给客户端,这就是代理模式。代理模式——就是给某一个对...

php websocket-网页实时聊天之PHP实现websocket(ajax长轮询和websocket都可以时间网络聊天室)

php websocket-网页实时聊天之PHP实现websocket(ajax长轮询和websocket都可以时间网络聊天室) 一、总结 1、ajax长轮询和websocket都可以时间网络聊天室 2、websocket:websocket是html5的新特性,是一种和http一个层次的协议 3、PHP 实现 websocket:PHP 实现 webso...

WCF安全:通过 扩展实现用户名密码认证

  在webSservice时代,可以通过SOAPHEADER的方式很容易将用户名、密码附加到SOAP header消息头上,用户客户端对调用客户端身份的验证。在WCF 时代,也可以通过OperationContext.Current.IncomingMessageHeaders的方式将用户名、密码附加到SOAP消息中。但是这种方式实现起来有个缺点;那就是...

golang grpc keepalive

最近遇到 grpc 客户端报错 rpc error: code = Unavailable desc = transport is closing,原因是连接长时间没有使用,被服务端断开,这种情况通过简单粗暴的重试策略可以解决,更加优雅的解决方案是增加保持连接策略 服务端 var kaep = keepalive.EnforcementPolicy{ M...

iperf3

使用方法 一、首先是介绍:iperf3是一个网络带宽测试工具,iperf3可以擦拭TCP和UDP带宽质量。iperf3可以测量最大TCP带宽,具有多种参数和UDP特性,iperf3可以报告带宽、延迟抖动和数据包丢失。 二、使用iperf3,你可以调整与时序、缓冲区和协议(如TCP、UDP、SCTP)相关的几个参数。它对网络性能调优操作很方便,为了获得最大或...

MQTT协议的简单介绍和服务器的安装

转:http://blog.csdn.net/djun100/article/details/25752491   最近公司做的项目中有用到消息推送,经过多方面的筛选之后确定了使用MQTT协议,相对于XMPP,MQTT更加轻量级,并且占用用户很少的带宽。 MQTT是IBM推出的一种针对移动终端设备的基于TCP/IP的发布/预订协议,可以连接大量的远程传感器...