zoukankan      html  css  js  c++  java
  • socket链接

    服务端:
    package com.batch.service.impl;
    
    import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class serverSoecktMain {
        public static void main(String[] args) {
               ServerSocket server = null;
               Socket socket = null;
               BufferedReader br = null;
               PrintWriter pr =null;
              try {
                   try {
                    server = new ServerSocket(6666);
                   } catch (Exception e) {
                    System.out.println("can not listen to:" + e);
                   }
                   System.out.println("server------------------------------");
                   try {
                    socket = server.accept();
                   } catch (Exception e) {
                    System.out.println("Error." + e);
                   }
                   br= new BufferedReader(new InputStreamReader(socket.getInputStream()));
                   pr= new PrintWriter(socket.getOutputStream());
                   pr.println("服务端:this is a server");
                   pr.flush();
                   System.out.println("Client:" + br.readLine());
                  } catch (Exception e) {
                   System.out.println("Error:" + e);
                  } finally{
                      try {
                        server.close();
                        socket.close();
                        br.close();
                        pr.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                  }
        }
    }
    
    客户端:
    package com.batch.service.impl;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    public class serverMain {
        public static void main(String[] args) {
            Socket socket= null;
            PrintWriter pr= null;
            BufferedReader br = null;
            try {
                   socket = new Socket("127.0.0.1",6666);
                   pr = new PrintWriter(socket.getOutputStream());
                   br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                   System.out.println("Client------------------------------");
                   pr.println("client is good!");
                   pr.flush();
                   System.out.println("Server:" + br.readLine());
                  } catch (Exception e) {
                   System.out.println("Error" + e); //错则打印错信息
                  } finally{
                      try {
                        socket.close();
                        pr.close();
                        br.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                  }
        }
    }
    休闲玩家 佛系更博
  • 相关阅读:
    一个有关Golang Deferred Function 执行顺序的问题
    Golang闭包的坑
    Golang new() vs make()
    修改linux文件的mtime
    Golang通过反射获取结构体的标签
    rpm --qf 命令
    elasticsearch 5.1 认证过期 (your license has expired)
    Heka GeoIpDecoder 配置
    Heka 编译安装后 运行报错 panic: runtime error: cgo argument has Go pointer to Go pointer
    github.com/oschwald/maxminddb-golang 安装报错
  • 原文地址:https://www.cnblogs.com/yuyuchen/p/8241955.html
Copyright © 2011-2022 走看看