多线程TCP服务器

相关Java类

Socket

public class Socket extends Object

  • 功能:TCP客户端套接字
  • 构造方法: Socket(InetAddress address, int port) 创建一个流套接字并将其连接到指定 IP 地址的指定端口号
  • 常用方法:
    1. getInetAddress 获得InetAddress的相关信息
    2. getInputStream 获得此TCP连接的输入流
    3. getOutPutStream 获得此TCP连接的输出流

ServerSocket

public class ServerSocket extends Object

  • 功能: TCP服务端套接字
  • 构造方法: ServerSocket(int port) 创建绑定到特定端口的服务器套接字。
  • 常用方法:
    1. accept 获得TCP连接的客户端的socket
    2. isClosed 获得ServerSocket的关闭状态

TCP服务器端

TcpServer.java

服务器端采用多线程的方式,每建立一个连接就启动一个java线程,发送图片给客户端,之后关闭此TCP连接

package cn.xidian.tcpSocket;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TcpServer extends Thread{
    Socket clientSocket;

    public TcpServer(Socket clientSocket) {
        super();
        this.clientSocket = clientSocket;
    }

    @Override
    public void run() {
        try {
            //获得客户端的ip地址和主机名
            String clientAddress = clientSocket.getInetAddress().getHostAddress();
            String clientHostName = clientSocket.getInetAddress().getHostName();
            System.out.println(clientHostName + "(" + clientAddress + ")" + " 连接成功!");
            System.out.println("Now, 传输图片数据...........");
            long startTime = System.currentTimeMillis();
            //获取客户端的OutputStream
            OutputStream out = clientSocket.getOutputStream(); 
            //传出图片数据
            FileInputStream in = new FileInputStream(new File("/home/gavinzhou/test.jpg")); 
            byte[] data = new byte[4096];
            int length = 0;
            while((length = in.read(data)) != -1){
                out.write(data, 0, length); //写出数据
            }
            long endTime = System.currentTimeMillis();
            //提示信息
            System.out.println(clientHostName + "(" + clientAddress + ")" + " 图片传输成功," + "用时:" + ((endTime-startTime)) + "ms");
            //关闭资源
            in.close();
            clientSocket.close();
            System.out.println("连接关闭!");
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    public static void main(String[] args) throws IOException {
        //建立TCP连接服务,绑定端口
        ServerSocket tcpServer = new ServerSocket(9090);
        //接受连接,传图片给连接的客户端,每个TCP连接都是一个java线程
        while(true){
            Socket  clientSocket = tcpServer.accept();
            new TcpServer(clientSocket).start();
        }

    }

}

TCP客户端

TcpClient

package cn.xidian.tcpSocket;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.Socket;

public class TcpClient {

    public static void main(String[] args) throws IOException {
        // 建立TCP服务
        // 连接本机的TCP服务器
        Socket socket = new Socket(InetAddress.getLocalHost(), 9090);
        // 获得输入流
        InputStream inputStream = socket.getInputStream();
        // 写入数据
        FileOutputStream out = new FileOutputStream(new File("../save.jpg"));
        byte[] data = new byte[4096];
        int length = 0;
        while((length = inputStream.read(data)) != -1){
            out.write(data, 0, length);
        }
        //关闭资源
        out.close();
        socket.close();
    }


}

结果

首先,命令行启动服务器端,之后启动客户端,结果如下:

图片比较小,速度很快!

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏java 成神之路

java中设置网络代理

1.2K6
来自专栏Golang语言社区

Golang通过socket与java通讯

下面上代码: //server.go //客户端,主要是在9000端口创建监听程序,用于接受客户端连接 package main import ( ...

3966
来自专栏IT笔记

JAVA实现的微信扫描二维码支付

吐槽一下 支付项目采用springMvc+Dubbo架构实现,只对外提供接口。 话说,为什么微信支付比支付宝来的晚了那么一点,一句话,那一阵挺忙的,然后就没有时...

1.5K8
来自专栏Jackson0714

Ubuntu 安装phpMyAdmin + 配置nginx

sudo ln -s /usr/share/phpMyAdmin /usr/share/nginx/html

1543
来自专栏冷冷

【springboot】 springboot 整合mybatis-plus

springboot整和mybatis-plus 整合步骤 1.pom.xml 添加mp依赖 <!-- mybatis-plus begin --> <depe...

4869
来自专栏LIN_ZONE

jsp 自定义标签解决jsp页面中int时间戳的时间格式化问题

之前在项目中根据需求,需要自定义标签,经过查询w3c文档,自己也踩了一些坑,特此记录自定义标签的步骤,下面就以我之前的一个例子中的定义一个时间转换标签为例:gi...

942
来自专栏王磊的博客

WebApi开启CORS支持跨域POST

概念:CORS是一个W3C标准,全称是"跨域资源共享"(Cross-origin resource sharing)。它允许浏览器向跨源服务器,发出XMLHtt...

4218
来自专栏精讲JAVA

Bio、Nio、Aio的用法系列之BIO(一)

上面我们开始监听8888端口,启动这个main后,肯定阻塞到accept,等待客户端发送过来消息

1283
来自专栏xingoo, 一个梦想做发明家的程序员

Java程序员的日常 —— 多进程开发

最近再弄进程管理相关的工作,因此必要的就涉及到各种系统下关于进程的管理。 这里简单的介绍下: 如何在Java中执行命令 在windows下肯定是dos命...

2629
来自专栏LIN_ZONE

jsp 自定义标签解决jsp页面中int时间戳的时间格式化问题

之前在项目中根据需求,需要自定义标签,经过查询w3c文档,自己也踩了一些坑,特此记录自定义标签的步骤,下面就以我之前的一个例子中的定义一个时间转换标签为例:gi...

862

扫码关注云+社区

领取腾讯云代金券