Socket通信程序设计

一、客户端相关内容

1、客户端的程序使用Socket类建立与服务器的套接字连接。向服务器端发出连接请求

由于在使用Socket构造方法创建Socket对象时会产生IOException异常，所以在创建Socket对象时应处理IOException异常
如：

  try{
Socket socket=new Socket(http://www.gduf.edu.cn,1880);
}catch(IOException e){
}

2、getInputStream()方法读取服务器放入线路中的信息

Socket对象socket可以使用getInputStream()方法获得输入流，利用这个输入流读取服务器放入线路中的信息
如：

BufferedReader cin=new BufferedReader(new InputStreamReader(socket.getInputStream()));

3、getOutputStream()方法将数据写入线路

如：

PrintStream cout=new PrintStream(socket.getOutputStream());
或
DateOutputStream cout=new DateOutputStream(socket.getInputStream());

二、服务器端相关内容

1、服务器端的程序使用ServerSocket类建立一个等待接收客户套接字的服务器套接字。

同样在使用ServerSocket构造方法创建ServerSocket对象时也会产生IOException异常，所以在创建ServerSocket对象时也应处理IOException异常
如：

  try{
ServerSocket serSocket=new ServerSocket(1880);
}catch(IOException e){
}

2、accept()方法接收客户的套接字mySocket 等待连接

try{
Socket sc=serSocket.accept();
}catch(IOException e){
}
将收到的客户端的mySocket放到一个已经声明的Socket对象 sc中。

3、getOutputStream()方法服务器端向线路写信息，发送到线路端

将收到的客户端的mySocket放到一个已经声明的Socket对象 sc中。这样服务器的sc就可以使用getOutputStream()方法获得输出流，然后用这个输出流向线路写信息，发送到客户端

BufferedReader sin=new BufferedReader(new InputStreamReader(socket.getInputStream()));

4、getInputStream()方法读取客户放入线路中的信息

服务器的sc可以使用getInputStream()方法获得输入流，然后用这个输入流读取客户放入线路的信息

PrintStream sout=new PrintStream(socket.getOutputStream());
或
DateOutputStream sout=new DateOutputStream(socket.getInputStream());

三、Socket通信的步骤如下：

（1）在服务器端创建一个ServerSocket对象，并指明端口号

（2）运行ServerSocket的accept()方法，等候客户端请求

（3）客户端创建一个Socket对象，指定服务器的IP地址和端口号，向服务器端发出连接请求

（4）服务器端接收到客户端请求后，创建Socket对象与客户端建立联系

（5）服务器端和客户端分别建立输入输出数据流，进行数据传输

（6）通信结束后，服务器端和客户端分别关闭相应的Socket连接

（7）服务器端程序运行结束后，调用ServerSocket对象的close()方法停止等候客户端请求

四、实际应用

1、实现客户端向服务器器端上传图片

class Client{
    public static void main(String[] args) throws IOException {
        //连接服务器 获取socket
        Socket socket = new Socket("127.0.0.1",8080);

        //创建服务器端对应的输入流 用于接收服务器端发来的数据
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        System.out.println(br.readLine());

        //向服务器端发送文件（图片)
        //1.将文件写入到内存里
        String path = "C:\\Users\\17153\\Desktop\\F.jpg";
        FileInputStream fis = new FileInputStream(path);

        //2.创建字节流 outputStream
        BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
        byte[] buf = new byte[1024];
        int len = -1;
        while ((len = fis.read(buf)) != -1){
            bos.write(buf,0,len);
        }
        socket.shutdownOutput();
    }
}

class Server{
    public static void main(String[] args) throws IOException {
        //创建服务器端的ServerSoket
        ServerSocket ss = new ServerSocket(8080);

        //监听客户端连接
        //当有客户端来连接这个服务器 就可以得到对应的socket
        //当没有客户端来连接 服务器一直在这里等待
        Socket socket = ss.accept();

        //创建客户端对应的输出流 用于向这个客户端发送数据
        PrintStream ps = new PrintStream(socket.getOutputStream());
        ps.println("连接成功 可以发数据了！");

        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
        String path = "D:\\android studio java\\lib1\\src\\main\\java\\swu\\syq\\lib6\\lib5\\1.jpg";
        FileOutputStream fos = new FileOutputStream(path);

        byte[] buf = new byte[1024];
        int len = -1;
        while((len = bis.read(buf)) != -1){
            fos.write(buf,0,len);
        }
    }
}

2、（使用多线程）对聊

//模拟客户端
class Client{
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("10.129.2.205",8000);
        //子线程 处理服务端数据
        new Thread(new ClientThread(socket)).start();

        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        //客户端的输出流对象
        PrintStream printStream = new PrintStream(socket.getOutputStream());
        String line = null;
        while ((line = keyin.readLine())!= null){
            printStream.println(line);
        }
    }
}

创建一个子线程 给客户端用于处理、接收服务器端的数据
class ClientThread implements Runnable{
    private Socket socket;
    //保存操作的socket 对象
    public ClientThread(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            //获取输入
            bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //读取
            String line = null;
            while ((line=bufferedReader.readLine()) != null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络出错  请重新登录");
            System.exit(-1);
        }finally {
            try {
                if (bufferedReader != null) {
                    bufferedReader.close();
                }
                if (socket != null) {
                    socket.close();
                }
            }catch (IOException e) {
                e.printStackTrace();
            }

        }
    }
}

//模拟服务器端
class Server{
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8000);

        Socket socket = serverSocket.accept();

        new ServerThread(socket).start();

        //终端输入流对象
        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        //客户端的输出流对象
        PrintStream printStream = new PrintStream(socket.getOutputStream());
        //读取终端的输入 输出给客户端
        String line = null;
        while ((line = keyin.readLine())!= null){
            printStream.println(line);
        }
    }
}

//创建一个子线程 给服务器端用于处理、接收客户端的数据
class ServerThread extends Thread{
    private Socket socket;
    public ServerThread(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            bufferedReader= new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String line = null;
            while ((line = bufferedReader.readLine())!=null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络异常 请重新登录");
        }finally {
            try{
                if(bufferedReader != null){
                    bufferedReader.close();
                }
                if (socket!= null){
                    socket.close();
                }

            }catch (IOException e){
                e.printStackTrace();
            }
        }
    }
}

3、群聊

和对聊只是Server类的区别需要一个数组来保存所有客户端发消息的时候是群发用遍历来实现

class Server{
    public static ArrayList<Socket> sockets = new ArrayList<>();
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8000);

        while (true){
            Socket socket = serverSocket.accept();
            //当客户连接过来就保存
            sockets.add(socket);

            new ServerThread(socket).start();
        }
    }
}
class Client{
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("10.129.2.205",8000);
        //子线程 处理服务端数据
        new Thread(new ClientThread(socket)).start();

        BufferedReader keyin = new BufferedReader(new InputStreamReader(System.in));
        //客户端的输出流对象
        PrintStream printStream = new PrintStream(socket.getOutputStream());
        String line = null;
        while ((line = keyin.readLine())!= null){
            printStream.println(line);
        }
    }
}
class ClientThread implements Runnable{
    private Socket socket;
    //保存操作的socket 对象
    public ClientThread(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            //获取输入
            bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //读取
            String line = null;
            while ((line=bufferedReader.readLine()) != null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络出错  请重新登录");
            System.exit(-1);
        }finally {
            try {
                if (bufferedReader != null) {
                    bufferedReader.close();
                }
                if (socket != null) {
                    socket.close();
                }
            }catch (IOException e) {
                e.printStackTrace();
            }

        }
    }
}
class ServerThread extends Thread{
    private Socket socket;
    public ServerThread(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        BufferedReader bufferedReader = null;
        try {
            bufferedReader= new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String line = null;
            while ((line = bufferedReader.readLine())!=null){
                System.out.println(line);
            }
        } catch (IOException e) {
            System.out.println("网络异常 请重新登录");
        }finally {
            try{
                if(bufferedReader != null){
                    bufferedReader.close();
                }
                if (socket!= null){
                    socket.close();
                }

            }catch (IOException e){
                e.printStackTrace();
            }
        }
    }
}

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 217,734评论 6赞 505
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 92,931评论 3赞 394
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 164,133评论 0赞 354
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 58,532评论 1赞 293
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 67,585评论 6赞 392
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 51,462评论 1赞 302
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 40,262评论 3赞 418
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 39,153评论 0赞 276
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 45,587评论 1赞 314
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,792评论 3赞 336
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,919评论 1赞 348
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,635评论 5赞 345
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 41,237评论 3赞 329
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,855评论 0赞 22
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,983评论 1赞 269
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 48,048评论 3赞 370
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,864评论 2赞 354