首页 > 编程语言 >java网络编程--3 TCP

java网络编程--3 TCP

时间:2022-10-03 20:12:48浏览次数:52  
标签:java socket -- TCP import close new Socket

java网络编程--3 TCP

1.6、TCP

客户端

  1. 连接服务器 Socket
  2. 发送消息
package com.ssl.lesson02;


import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

//客户端
public class TcpClientDemo01 {
    public static void main(String[] args) {
        Socket socket = null;
        OutputStream os = null;

        try {
            //1.要知道服务器的地址,端口号
            InetAddress serverIP = InetAddress.getByName("127.0.0.1");
            int port = 9999;
            //2.创建一个socket连接

            socket = new Socket(serverIP,port);

            //3.发送消息,IO流
            os = socket.getOutputStream();
            os.write("你瞅啥".getBytes());


        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if(os!=null){
                try {
                    os.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }

            if (socket!=null) {
                try {
                    socket.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
        }

    }
}

服务端

  1. 建立服务的端口ServerSocket
  2. 等待用户连接accept
  3. 接收用的消息
package com.ssl.lesson02;


import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

//服务端
public class TcpServicerDemo01 {
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        Socket socket = null;
        InputStream is = null;
        ByteArrayOutputStream baos = null;
        try {
            //1.我得有一个地址,服务插槽
            serverSocket = new ServerSocket(9999);
            while(true) {

                //2.等待客户端连接过来
                socket = serverSocket.accept();
                //3.读取客户端的消息
                is = socket.getInputStream();
                //初学者读取方式
            /*  会出现乱码
            byte[] buffer = new byte[1024];
            int len;
            while((len=is.read(buffer))!=-1){
                String msg =new String(buffer,0,len);
                System.out.println(msg);
            }
            */
                //管道流
                baos = new ByteArrayOutputStream();
                byte[] buffer = new byte[1024];
                int len;
                while ((len = is.read(buffer)) != -1) {
                    baos.write(buffer, 0, len);
                }
                System.out.println(baos.toString());
            }

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            //关闭资源流
            if(baos!=null){
                try {
                    baos.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if(is!=null){
                try {
                    is.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if(socket!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if(serverSocket != null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }

        }

    }
}

文件上传

客户端:

package com.ssl.lesson02;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;

public class TcpClientDemo02 {
    public static void main(String[] args) throws Exception{
        //1.创建一个Socket连接
        Socket socket = new Socket(InetAddress.getByName("127.0.0.1"),9000);
        //2.创建一个输出流
        OutputStream os = socket.getOutputStream();
        //3.文件流,读取文件
        FileInputStream fis = new FileInputStream(new File("1.jpg"));
        //4.写出文件
        byte[] buffer = new byte[1024];
        int len;
        while((len=fis.read(buffer))!=-1){
            os.write(buffer,0,len);
        }
        //通知服务器我已经结束了
        socket.shutdownOutput();  //我已经传输完了

        //确定服务器接收完毕,才能够断开连接
        InputStream is = socket.getInputStream();
        //String byte[]
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        byte[] buffer2 = new byte[1024];
        int len2;
        while((len2=is.read(buffer2))!=-1){
            baos.write(buffer2,0,len2);
        }

        System.out.println(baos.toString());

        //5.关闭资源
        baos.close();
        is.close();
        fis.close();
        os.close();
        socket.close();
    }
}

服务端:

package com.ssl.lesson02;

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TcpServicerDemo02 {
    public static void main(String[] args) throws Exception{
        //1.创建服务
        ServerSocket serverSocket = new ServerSocket(9000);
        //2.监听客户端的连接
        Socket socket = serverSocket.accept();  //阻塞式监听,会一直等待客户端连接
        //3.获取输入流
        InputStream is = socket.getInputStream();
        //4.文件输出
        FileOutputStream fos = new FileOutputStream(new File("receive.png"));
        byte[] buffer = new byte[1024];
        int len;
        while((len=is.read(buffer))!=-1){
            fos.write(buffer,0,len);
        }
        //通知客户端,我接收完毕了
        OutputStream os = socket.getOutputStream();
        os.write("我接收完毕了,可以断开了".getBytes());

        //5.关闭输入输出
        os.close();
        fos.close();
        is.close();
        socket.close();
        serverSocket.close();

    }

}

Tomcat

服务端:

  • 自定义S
  • Tomcat服务器

客户端:

  • 自定义C
  • 浏览器

标签:java,socket,--,TCP,import,close,new,Socket
From: https://www.cnblogs.com/ssl-study/p/16751122.html

相关文章

  • 代码审计小tips(一)
    代码审计的源码获取通过fofa进行指纹识别提取关键指纹将获取到的关键信息去github和gitee进行获取源码网站如站长之家,zuidaima.com,bbs52jscn.com拖源码,获取目......
  • background-image(背景渐变)
    渐变背景原文链接:https://blog.csdn.net/Mq_sir/article/details/121053167一、线性渐变(向上\下\左\右,左上,右上等等)通过属性Inear-gradient来定义一个线性渐变1、to......
  • 注释、标识符和关键字、数据类型及其拓展
    注释、标识符和关键字publicclassHelloWorld{publicstaticvoidmain(String[]args){//单行注释//输出一个Hello,World!System.ou......
  • CSP模拟练习赛1 https://www.luogu.com.cn/contest/82861#problems
    P1321单词覆盖还原简单思路字符串#include<iostream>#include<cstdio>#include<cstring>#include<algorithm>#include<queue>#include<map>#definelllonglon......
  • 屏幕截图与定位识别
    #-*-coding:utf-8-*-importpyautoguiimportosfile_url=os.getcwd()+'/file/img.png'#屏幕截图defdemo1():pyautogui.screenshot(region=(0,0,......
  • 第二章:CSS基础
    CSS语法结构选择器{属性1:值1;属性2:值2;属性3:值3}注释/**/CSS三种导入方式外部引入方式外部引入方式就是将css写在一个单独的文件中,然后在页面进行引入即可......
  • 什么是Linux
    导读对于刚刚接触Linux的人来说,Linux到底是个什么往往不好解释。因为太过于常见而难以向从未接触过的新人作介绍,简单理解成哈利刚刚走入九又四分之三车站,一下子和原有的世......
  • python中getter和setter方法的使用
    classUserInfo(object):@propertydefusername(self):#这里返回的self.名字不能和函数名同名[email protected](self,usern......
  • Kubernetes--服务发现
    服务发现概述简单来说,服务发现就是服务或者应用之间互相定位的过程。不过,服务发现并非新概念,传统的单体应用架构也会用到,只不过单体应用的动态性不强,更新和重新发布的频......
  • 实验2:Open vSwitch虚拟交换机实践
    一、实验目的能够对OpenvSwitch进行基本操作;能够通过命令行终端使用OVS命令操作OpenvSwitch交换机,管理流表;能够通过Mininet的Python代码运行OVS命令,控制网络拓扑中的......