资讯专栏INFORMATION COLUMN

一个简单的支持多并发的socket服务/客户端

Honwhy / 1821人阅读

摘要:代码实战启动类服务启动类启动类线程监听端口服务类监听端口主服务监听端口服务端启动成功,端口服务端启动失败线程模式,防止注释启动客户端接受服务端异常客户端接入监听类客户端接入监听类数据连接值新客户端接入对客户端的业务处理,接收并重写回去客户

代码实战 ServerBoot启动类
package com.example.demo.server;

/**
 * @author  MySelf
 * @create  2018/9/29
 * @desc 服务启动类
 **/
public class ServerBoot {

    private static final int PORT = 8000;

    /**
     * 启动Server类线程
     * @param args
     */
    public static void main(String[] args) {
        Server server = new Server(PORT);
        server.start();
    }

}
Server监听端口服务类
package com.example.demo.server;

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

/**
 * @author  MySelf
 * @create  2018/9/29
 * @desc Server监听端口主服务
 **/
public class Server {

    private ServerSocket serverSocket;

    /**
     * 监听端口
     * @param port
     */
    public Server(int port){
        try {
            this.serverSocket = new ServerSocket(port);
            System.out.println("服务端启动成功,端口:"+port);
        }catch (IOException e){
            System.out.println("服务端启动失败");
        }
    }

    /**
     * 线程模式,防止注释
     */
    public void start(){
        new Thread(new Runnable() {
            @Override
            public void run() {
                doStart();
            }
        }).start();
    }

    /**
     * 启动客户端接受
     */
    private void doStart() {
        while (true){
            try {
                Socket client = serverSocket.accept();
                new ClientHandler(client).start();
            }catch (IOException e){
                System.out.println("服务端异常");
            }
        }
    }

}
ClientHandler客户端接入监听类
package com.example.demo.server;

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

/**
 * @author  MySelf
 * @create  2018/9/29
 * @desc 客户端接入监听类
 **/
public class ClientHandler {

    /** 数据连接值 */
    public static final int MAX_DATA_LEN = 1024;
    private final Socket socket;

    public ClientHandler(Socket socket){
        this.socket = socket;
    }

    public void start(){
        System.out.println("新客户端接入");
        new Thread(new Runnable() {
            @Override
            public void run() {
                doStart();
            }
        }).start();
    }

    /**
     * 对客户端的业务处理,接收并重写回去
     */
    private void doStart(){
        try {
            InputStream inputStream = socket.getInputStream();
            while (true){
                byte[] data = new byte[MAX_DATA_LEN];
                int len;
                while((len = inputStream.read(data)) != -1){
                    String message = new String(data,0,len);
                    System.out.println("客户端传来消息:"+message);
                    socket.getOutputStream().write(data);
                }
            }
        }catch (IOException e){
            e.printStackTrace();
        }
    }

}
Client客户端启动类
package com.example.demo.client;

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

/**
 * @author  MySelf
 * @create  2018/9/29
 * @desc 客户端启动类
 **/
public class Client {

    private static final String HOST = "127.0.0.1";
    private static final int PORT = 8000;
    private static final int SLEEP_TIME = 5000;

    public static void main(String[] args) throws IOException {

        final Socket socket = new Socket(HOST,PORT);

        /**
         * 客户端启动,定时向服务端发送数据
         */
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("客户端启动成功!");
                while (true){
                    try {
                        String message = "hello world";
                        System.out.println("客户端发送数据:"+message);
                        socket.getOutputStream().write(message.getBytes());
                    }catch (Exception e){
                        System.out.println("写数据出错!");
                    }
                    sleep();
                }
            }
        }).start();
    }

    private static void sleep() {
        try {
            Thread.sleep(SLEEP_TIME);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}
相关实战

GitHub项目:基于Netty4与SpringBoot,聊天室WebSocket(文字图片)、Iot物联网-TCP/IP协议单片机通信,异步存储聊天数据

如果本文对你有所帮助,欢迎关注技术公众号。

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/77348.html

相关文章

  • PHP并发IO编程之路

    摘要:下文如无特殊声明将使用进程同时表示进程线程。收到数据后服务器程序进行处理然后使用向客户端发送响应。现在各种高并发异步的服务器程序都是基于实现的,比如。 并发 IO 问题一直是服务器端编程中的技术难题,从最早的同步阻塞直接 Fork 进程,到 Worker 进程池/线程池,到现在的异步IO、协程。PHP 程序员因为有强大的 LAMP 框架,对这类底层方面的知识知之甚少,本文目的就是详细介...

    Riddler 评论0 收藏0
  • Nginx实现内参

    摘要:子进程启动后监控维护区。每来一个新的连接都会触发新的事件,这些事件送给内的状态机来处理。大部分的逻辑上都有这样的状态机,只是实现方式不一样。另外通过进程绑定技术可以进一步减少上下文切换和失效等系统开销。 Nginx在web开发者眼中就是高并发高性能的代名词,其基于事件的架构也被众多开发者效仿。我从Nginx的网站找到一篇技术文章将Nginx是怎样实现的,文章是Nginx的产品老大Owe...

    learn_shifeng 评论0 收藏0
  • 物联网高并发编程之单台服务器最大并发TCP连接数

    摘要:对端,通过增加内存修改最大文件描述符个数等参数,单机最大并发连接数超过万甚至上百万是没问题的,国外公司在产品环境中已做到万并发 [TOC] 前言 曾几何时我们还在寻求网络编程中C10K问题的解决方案,但是现在从硬件和操作系统支持来看单台服务器支持上万并发连接已经没有多少挑战性了。 我们先假设单台服务器最多只能支持万级并发连接,其实对绝大多数应用来说已经远远足够了,但是对于一些拥有很大用...

    leap_frog 评论0 收藏0
  • 如何打造在线直播间(技术贴)

    摘要:背景当下视频直播如此红火,打造一个在线直播间涉及到哪些技术呢视频直播由主播的直播端以及观众的观看端组成。保持心跳断开重连快速搭建在线直播间按前文所述,搭建直播间有非常多的细节需要考虑,包括采集推流分发播放体验优化聊天室性能调优等。 背景 当下视频直播如此红火,打造一个在线直播间涉及到哪些技术呢? 视频直播由主播的直播端以及观众的观看端组成。一个简单的观看端最起码应包含播放器以及聊天室。...

    sugarmo 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<