思享工具箱

在Java中使用Socket模拟客户端和服务端（多线程）

摘要：
如果成功，则返回Socket对象。我们可以将其理解为服务器和客户端，服务器提供连接服务，客户端链接服务器。

1：Socket与ServerSocket的交互

111

2.Socket和ServerSocket介绍

Socket

构造函数

Socket()

Socket(InetAddress address, int port)throws UnknownHostException, IOException

Socket(InetAddress address, int port, InetAddress localAddress, int localPort)throws IOException

Socket(String host, int port)throws UnknownHostException, IOException(最简单的连接方式)

Socket(String host, int port, InetAddress localAddress, int localPort)throws IOException

除去第一种不带参数的之外，其它构造函数会尝试建立与服务器的连接。如果失败会抛出IOException错误。如果成功，则返回Socket对象。

InetAddress是一个用于记录主机的类，其静态getHostByName(String msg)可以返回一个实例，其静态方法getLocalHost()也可以获得当前主机的IP地址，并返回一个实例。

Socket(String host, int port, InetAddress localAddress, int localPort)构造函数的参数分别为目标IP、目标端口、绑定本地IP、绑定本地端口。

Socket方法

getInetAddress();    远程服务端的IP地址

getPort();    远程服务端的端口

getLocalAddress()    本地客户端的IP地址

getLocalPort()    本地客户端的端口

getInputStream();    获得输入流

getOutStream();    获得输出流

值得注意的是，在这些方法里面，最重要的就是getInputStream()和getOutputStream()了。

Socket状态

isClosed();     //连接是否已关闭，若关闭，返回true；否则返回false

isConnect();　　　　　　//如果曾经连接过，返回true；否则返回false

isBound();     //如果Socket已经与本地一个端口绑定，返回true；否则返回false

ServerSocket

构造函数

ServerSocket()throws IOException

ServerSocket(int port)throws IOException

ServerSocket(int port, int backlog)throws IOException

ServerSocket(int port, int backlog, InetAddress bindAddr)throws IOException

注意点：

1. port服务端要监听的端口；backlog客户端连接请求的队列长度；bindAddr服务端绑定IP

2. 如果端口被占用或者没有权限使用某些端口会抛出BindException错误。譬如1~1023的端口需要管理员才拥有权限绑定。

3. 如果设置端口为0，则系统会自动为其分配一个端口；

4. bindAddr用于绑定服务器IP，为什么会有这样的设置呢，譬如有些机器有多个网卡。

5. ServerSocket一旦绑定了监听端口，就无法更改。ServerSocket()可以实现在绑定端口前设置其他的参数。

3.实例前说明

Socket网络编程主要用于两台机器之间的数据传输，大致过程为：建立连接→信息传递→关闭连接。我们可以理解为服务器（ServerSocket）和客户端（Socket）,服务器提供连接服务，客户端链接服务器。因为服务器需要向多台客户端提供服务，所以需要一直保持监听状态，不断地监听客户端请求，在这个过程中，ServerSocket一直处于阻断状态，直到有客户端连接，马上返回一个Socket对象，然后通过IO流传输数据，在这个过程中，当有数据传输的时候，IO流才被激活，其余时间都处于阻断状态，等待数据发送过来，然后进行处理。

注意：

当我们发送数据的时候，必须使用flush()方法，将数据提交，否则只会存在于缓冲中，不会发送数据，有时候即使我们使用flush()方法，也无法从另一台电脑上读取到数据，这是因为Socket会将数据先存储起来，等到数据量达到一定大小的时候，会一起提交（或者这样理解，flush()会根据换行符’ ’判断用户是否完成输入，如果没有看到’ ’,Socket认为用户数据还没有写完，仍在保留在缓存池中）所以我们可以在要提交的数据加上’ ’强制提交就可以了。

不过，如果我们没必要很多的交互，只需要交互一次就可以了，就可以不在乎这些，当关闭Socket的输入输出流的时候，Socket会将缓存池中的数据全部提交到另一台机器。

最后最重要的，当我们用完流的时候，一定要及时关闭，养成良好的习惯。

在下面的实例中，我通过多线程的方式保证服务器和客户端一直处于数据交互状态，并且使用线程池的方式维护线程。、

线程类：

package com.best.alivn.socketservice;
import java.io.*;
import java.net.Socket;
import java.util.Scanner;

/**让服务器处理与客户端通讯放在线程中
 * Created by Alivn on 2017/3/18.
 */
public class SessionThread  implements Runnable{

    private final Socket client;
    private static Integer Tag=0;

    public SessionThread(Socket client) {
        this.client = client;
    }

    @Override
    public void run() {

        //输出流
        PrintWriter writer=null;
        //获取客户端输入流，得到客户端发来的消息
        try {
            //读取客户端的数据
            //读取到的一行数据
            String line=null;
            //客户端发来的数据
            //开启一个读线程
           Thread write_thread= new Thread(new Runnable() {
                @Override
                public void run() {
                    //输入流
                    InputStream inputStream=null;
                    BufferedReader reader=null;
                    try {
                        while (true) {

                            inputStream= client.getInputStream();
                            //为了提高效率，转换成字符流
                            reader=new BufferedReader(new InputStreamReader(inputStream));
                            String line=null;
                      while ((line=reader.readLine())!=null)
                            {
                            System.out.println(line);
                            }
                        }
                    } catch (IOException e) {
                        //流异常
                        e.printStackTrace();
                    }finally {
                            //关闭流
                        try {
                            inputStream.close();
                            reader.close();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }

                    }
                }
            });
           write_thread.start();
            //获取输出流，往客户端发送数据
             writer=new PrintWriter(client.getOutputStream());
            //客户端刚连接的时候，客户端反馈信息
            String send_msg ="您已成功连接到服务器......--[Server]";
            writer.println(send_msg);
            writer.flush();
            //可以多次发送
            //从键盘输入
            while ("1".equals("1")) {
                Scanner scanner=new Scanner(System.in);
                send_msg =scanner.nextLine()+"--[Server]";
                writer.println(send_msg);
                //注意（我们发送数据的时候，flush方法会提交我们的数据，但是还不会发送，当数据达到一定容量才会发送，
                // 或者读到换行符的时候发送）
                writer.flush();
            }

        } catch (IOException e) {
            //获取客户端输入流失败
            e.printStackTrace();
        }finally {
            //关闭流
            try {
                client.shutdownInput();
                client.shutdownOutput();
                writer.close();
            } catch (IOException e) {
                //关闭输入输出流失败
                e.printStackTrace();
            }


        }

    }
}

服务器类：

package com.best.alivn.socketservice;
import scala.actors.threadpool.ExecutorService;
import scala.actors.threadpool.Executors;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;


/**服务器
 * Created by Alivn on 2017/3/18.
 */
public class Server {

    //甚至端口号
    private  final static Integer PORT=8888;
    //设置开启的线程数
    private  final  static  Integer THREAD_SIZE=5;
    //创建线程池
    private  static  ExecutorService executorService=null;
    public static void main(String[]args)
    {
        executorService  = Executors.newFixedThreadPool(THREAD_SIZE);
        //创建服务器套接字
        try {
            //创建三个线程放入到线程池中....
            ServerSocket serverSocket=new ServerSocket(PORT);
            //开启服务器，一直处于监听的状态
            System.out.println("[Server]:服务器已启动.........");
            while (true)
            {
                //服务器根据端口号，监听客户端链接，
                Socket client = serverSocket.accept();
                System.out.println("[Server]：有客户端链接至服务器.......");
               //将交互放到线程中
                SessionThread session=new SessionThread(client);
                //放入到线程池中
                session.run();
              executorService.execute(session);
            }
        } catch (IOException e) {
            //实例化服务器失败
            e.printStackTrace();
        }

    }

}
客户端类：
package com.best.alivn.socketservice;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

/**客户端
 * Created by Alivn on 2017/3/18.
 */
public class Client {

    private final  static  String host="localhost";
    private final  static  Integer port=8888;
    public  static  void main(String[] args)  {
        Socket socket=null;
        //输入流
        BufferedReader reader=null;

        //创建客户端对象
        try {
            //连接服务器
             socket=new Socket(host,port);
            //客户端刚连接的时候，客户端反馈信息
            //输出流
            final PrintWriter writer=new PrintWriter(socket.getOutputStream());;
            String  send_msg ="你好，我是小白......--[Client]";
            writer.println(send_msg);
            writer.flush();
            //开启一个线程，处理循环
         Thread write_Stream=  new Thread(new Runnable() {
                @Override
                public void run() {
                    //循环输入数据
                    Scanner scanner=new Scanner(System.in);
                    while ("1".equals("1"))
                    {
                        String send_msg=scanner.nextLine()+"--[Client]";
                        writer.println(send_msg);
                        writer.flush();
                    }
                }
            });
            write_Stream.start();
            while ("1".equals("1")) {
                //获取输入流，得服务端的数据
               reader=new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String line=null;
            while ((line=reader.readLine())!=null)
            {
                System.out.println(line);
            }
            }
            writer.close();
        } catch (IOException e) {
            //链接失败   文件读取失败
            e.printStackTrace();
        }finally {
            //关闭流
            try {
                reader.close();

                socket.shutdownInput();
                socket.shutdownOutput();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }


    }
}

标签：#socket#客户端服务器 | 浏览：402 | 发布日期：

免责声明：文章转载自《在Java中使用Socket模拟客户端和服务端（多线程）》仅用于学习参考。如对内容有疑问，请及时联系本站处理。

上篇Django web编程2 -- 编辑页面内容VSTO+WinForm+WebService+WCF+WPF示例下篇

宿迁高防，2C2G15M，22元/月；香港BGP，2C5G5M，25元/月 雨云优惠码：MjYwNzM=

相关文章

C# Socket服务器端如何判断客户端断开

使用Socket类中的Poll方法，就可以。 Socket client //假如已经创建好了，连接到服务器端得Socket的客户端对象。 我们只要client.Poll(10,SelectMode.SelectRead)判断就行了。只要返回True是。就可以认为客户端已经断开了。 Poll 方法将会检查 Socket 的状态。指定 selectMode...

C# Socket网络编程精华篇

我们在讲解Socket编程前，先看几个和Socket编程紧密相关的概念： TCP/IP层次模型     当然这里我们只讨论重要的四层        01，应用层(Application)：应用层是个很广泛的概念，有一些基本相同的系统级TCP/IP应用以及应用协议，也有许多的企业应用和互联网应用。http协议在应用层运行。        02，传输层(Tan...

Flink作业使用windows的nc命令产生socket流

首先windows安装netcat 1 在命令行窗口使用  nc -lp 8888 2  开启Flink任务（socket源的datastream） 3  在命令行输入内容：  作业停止后nc自动停止  在使用中必须按照1，2，3的顺序，否则在命令行输入字符无效，或Flink作业启动失败。踩过的坑记录一下...

POP3与IMAP协议

POP3与IMAP都是与电子邮件相关的协议。 POP3协议允许电子邮件客户端下载服务器上的邮件，但是在客户端的操作（如移动邮件、标记已读等），不会反馈到服务器上，比如通过客户端收取了邮箱中的3封邮件并移动到其他文件夹，邮箱服务器上的这些邮件是没有同时被移动的 。 即POP3协议实际上主要是用于下载的，只是对邮件服务器上的邮件进行的拷贝，并不构成与邮件服务器...

SSH的通讯和认证

SSH的通讯和认证 转自：http://blog.sina.com.cn/s/blog_4e9440910100zxk0.html 之前一直对SSH的认证模棱两可，今天对SSH的通讯，认证和配置有了进一步的学习。 大多数文档都没有将SSH的连线加密通讯和SSH的登录加密认证特别地区分来讲，对于我这种对密钥不太熟悉的人来说常常引起一些歧义。 首先，必须把通讯...

C#工作总结（一）：Fleck的WebSocket使用

一.引子（Foreword）       最近公司里面要做窗体和网页交互的功能。网上找了一下资料，这里做一个简单的扩充和整理，部分内容可能是摘自其他博客，这里会注明出处和原文地址供大家和自己日后查阅。 二.基础知识（Foundation） （1）. WebSocket介绍        WebSocket协议是基于TCP的一种新的网络协议。它实现了浏览器与...

最新文章

随机推荐

思享工具箱导航