Java基于Socket实现简单的多线程回显服务器功能示例

本文实例讲述了Java基于Socket实现简单的多线程回显服务器功能。分享给大家供大家参考，具体如下：

需要两个类，一个是EchoServer，代表服务器。另外一个是EchoServerClient，代表客户端。代码如下：

package interview;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class EchoServer {
  public static void main(String []args) throws IOException{
    ServerSocket server = new ServerSocket(6789);
    while(true){
      Socket client = server.accept();
      ClientHandler handler = new ClientHandler(client);
      new Thread(handler).start();
    }
  }
  public static class ClientHandler implements Runnable{
    private Socket client;
    @Override
    public void run() {
      InputStreamReader isr = null;
      try {
        isr = new InputStreamReader(client.getInputStream());
        BufferedReader br = new BufferedReader(isr);
        PrintWriter pw = new PrintWriter(client.getOutputStream());
        String msg = br.readLine();
        System.out.println("收到" + client.getInetAddress() + "发送的" + msg);
        pw.println("收到了你发的" + msg);
        pw.flush();
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
    public ClientHandler(Socket client){
      this.client = client;
    }
  }
}

下面是客户端代码：

package interview;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class EchoServerClient {
  public static void main(String []args) throws UnknownHostException, IOException{
    Socket client = new Socket("127.0.0.1", 6789);
    Scanner sc = new Scanner(System.in);
    System.out.print("请输入要发送的内容：");
    String msg = sc.nextLine();
    sc.close();
    PrintWriter pw = new PrintWriter(client.getOutputStream());
    pw.println(msg);
    pw.flush();
    InputStreamReader isr = new InputStreamReader(client.getInputStream());
    BufferedReader br = new BufferedReader(isr);
    System.out.println("服务器返回：" + br.readLine());
    client.close();
  }
}

NIO多路复用套接字方法如下：

package interview;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.CharacterCodingException;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.nio.charset.CharsetEncoder;
import java.util.Iterator;
public class EchoServerNIO {
  private static ServerSocketChannel serverChannel = null;
  private static Selector selector = null;// 多路复用选择器
  private static ByteBuffer buffer = null;  // 缓冲区
  public static void main(String []args) throws IOException{
    init();
    listen();
  }
  static void init() throws IOException{
    serverChannel = ServerSocketChannel.open();
    buffer = ByteBuffer.allocate(1024);
    serverChannel.socket().bind(new InetSocketAddress(6789));
    serverChannel.configureBlocking(false);
    selector = Selector.open();
    serverChannel.register(selector, SelectionKey.OP_ACCEPT);
  }
  static void listen() throws IOException{
    while(true){
      if(selector.select(5000) != 0){
        Iterator<SelectionKey> it = selector.selectedKeys().iterator();
        while(it.hasNext()){
          SelectionKey key = it.next();
          it.remove();
          handleKey(key);
        }
      }
    }
  }
  static void handleKey(SelectionKey key) throws IOException{
    SocketChannel channel = null;
    if(key.isAcceptable()){
      ServerSocketChannel serverChannel = (ServerSocketChannel)key.channel();
      channel = serverChannel.accept();
      channel.configureBlocking(false);
      channel.register(selector, SelectionKey.OP_READ);
    }else if(key.isReadable()){
      channel = (SocketChannel)key.channel();
      buffer.clear();
      if(channel.read(buffer) > 0){
        buffer.flip();
        CharBuffer charBuffer = CharsetHelper.decode(buffer);
        String msg = charBuffer.toString();
        System.out.println("收到" + channel.getRemoteAddress() + "的消息:" + msg);
        channel.write(CharsetHelper.encode(CharBuffer.wrap("received your msg:" + msg)));
      }
    }
  }
  public static class CharsetHelper{
    private static final String UTF_8 = "UTF-8";
    private static CharsetEncoder encoder = Charset.forName(UTF_8).newEncoder();
    private static CharsetDecoder decoder = Charset.forName(UTF_8).newDecoder();
    private CharsetHelper() {
    }
    public static ByteBuffer encode(CharBuffer in) throws CharacterCodingException{
      return encoder.encode(in);
    }
    public static CharBuffer decode(ByteBuffer in) throws CharacterCodingException{
      return decoder.decode(in);
    }
  }
}

更多关于java相关内容感兴趣的读者可查看本站专题：《Java Socket编程技巧总结》、《Java文件与目录操作技巧汇总》、《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

# Java  # Socket  # 多线程  # 回显  # 服务器  # Java实现基于NIO的多线程Web服务器实例  # java使用socket实现一个多线程web服务器的方法  # Java编程实现多线程TCP服务器完整实例  # Java编程利用socket多线程访问服务器文件代码示例  # java多线程实现服务器端与多客户端之间的通信  # Java多线程实现聊天客户端和服务器  # Java创建多线程服务器流程  # 多路  # 复用  # 客户端  # 操作技巧  # 相关内容  # 感兴趣  # 数据结构  # 给大家  # 请输入  # 另外一个  # 收到了  # 更多关于  # 所述  # 程序设计  # 方法如下  # 选择器  # 编程技巧  # 讲述了  # Override 

相关文章： 建站主机选哪种环境更利于SEO优化？  实现点击下箭头变上箭头来回切换的两种方法【推荐】  如何快速建站并高效导出源代码？  微网站制作教程,不会写代码，不会编程，怎么样建自己的网站？  宝塔面板如何快速创建新站点？  微信小程序 input输入框控件详解及实例（多种示例）  常州企业网站制作公司,全国继续教育网怎么登录？  如何选择最佳自助建站系统？快速指南解析优劣  如何基于云服务器快速搭建网站及云盘系统？  简历在线制作网站免费,免费下载个人简历的网站是哪些？  建站之星体验版：智能建站系统+响应式设计，多端适配快速建站  香港服务器网站测试全流程：性能评估、SEO加载与移动适配优化  简单实现Android文件上传  品牌网站制作公司有哪些,买正品品牌一般去哪个网站买？  合肥做个网站多少钱,合肥本地有没有比较靠谱的交友平台？  c# 在ASP.NET Core中管理和取消后台任务  如何快速选择适合个人网站的云服务器配置？  怎么将XML数据可视化 D3.js加载XML  如何快速搭建虚拟主机网站？新手必看指南  专业的网站制作设计是什么,如何制作一个企业网站，建设网站的基本步骤有哪些？  建站之家VIP精选网站模板与SEO优化教程整合指南  SAX解析器是什么，它与DOM在处理大型XML文件时有何不同？  制作电商网页,电商供应链怎么做？  如何快速搭建安全的FTP站点？  seo网站制作优化,网站SEO优化步骤有哪些？  php8.4新语法match怎么用_php8.4match表达式替代switch【方法】  制作国外网站的软件,国外有哪些比较优质的网站推荐？  一键网站制作软件,义乌购一件代发流程？  建站之星如何优化SEO以实现高效排名？  如何通过cPanel快速搭建网站？  如何通过二级域名建站提升品牌影响力？  建站之星代理费用多少？最新价格详情介绍  寿县云建站：智能SEO优化与多行业模板快速上线指南  外汇网站制作流程,如何在工商银行网站上做外汇买卖？  网站网页制作电话怎么打,怎样安装和使用钉钉软件免费打电话？  高端建站三要素：定制模板、企业官网与响应式设计优化  小说建站VPS选用指南：性能对比、配置优化与建站方案解析  济南网站建设制作公司,室内设计网站一般都有哪些功能？  宝塔建站教程：一键部署配置流程与SEO优化实战指南  济南网站制作的价格,历城一职专官方网站？  建站之星备案是否影响网站上线时间？  如何在云主机上快速搭建多站点网站？  rsync同步时出现rsync: failed to set times on “xxxx”: Operation not permitted  移民网站制作流程,怎么看加拿大移民官网？  Android滚轮选择时间控件使用详解  清单制作人网站有哪些,近日“兴风作浪的姑奶奶”引起很多人的关注这是什么事情？  黑客入侵网站服务器的常见手法有哪些？  如何用搬瓦工VPS快速搭建个人网站？  建站之星多图banner生成与模板自定义指南  免费网站制作模板下载,除了易企秀之外还有什么H5平台可以制作H5长页面，最好是免费的？