zoukankan      html  css  js  c++  java
  • 基于TCP协议的客户端

     基于TCP协议的客户端 此客户端能用于下一篇博客的单线程服务器和多线程服务器

    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.InetAddress;
    import java.net.Socket;
    import java.util.Scanner;
    import java.util.Timer;
    import java.util.TimerTask;
     
    public class JabberClient
    {
     
        public static void main(String[] args) throws IOException
        {
            new KeHuJi();
        }
    }
     
    class KeHuJi
    {
        BufferedReader in = null;
        PrintWriter out = null;
        public  String name = null;
     
        class JieShou extends TimerTask//每隔一段时间就检查本地这个端口是否有新的消息发送过来
        {
            public void run()
            {
                String string = null;
                try
                {
                    string = in.readLine();
                    if (string != null)
                    {
                        System.out.println(string);
                    }
                } catch (Exception e)
                {
                    // TODO: handle exception
                }
     
            }
        }
     
        public KeHuJi() throws IOException
        {
            InetAddress addr = InetAddress.getLocalHost();
            Socket socket = null;
            String ipString = null;
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入服务器的ip");
            ipString = scanner.next();
            socket = new Socket(ipString, 8089);//创建一个客户对象并与服务器相连  端口是8089,此时服务器会收到一个连接请求
            System.out.println("请输入的你的名字");
            name = scanner.next();
            scanner.close();
            try
            {
                System.out.println("连接成功");
                in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                out = new PrintWriter(socket.getOutputStream(), true);
     
                Timer timer = new Timer();
                JieShou jieShou = new JieShou();
                timer.schedule(jieShou, 10, 200);//每隔200毫秒就接收一次服务器发来的消息
                while (true)//发送消息
                {
                    Scanner in1 = new Scanner(System.in);
                    out.println(name + ":  " + in1.next());
                }
     
            } catch (Exception e)
            {
            }
            finally
            {
                socket.close();
            }
        }
    }
    梦里不知身是客,一晌贪欢。
  • 相关阅读:
    hibernate中的缓存和快照
    hibernate中的主键生成策略
    static静态代码块的使用(单例)
    spring aop简单实现
    spring 中常用注解
    spring 配置文件中<property> 的作用
    spring配置文件中引入其他配置文件的方法
    3-29 from xx import xx
    3-28 遇到的问题及解决方法
    3-27 思考以及self本质
  • 原文地址:https://www.cnblogs.com/dccmmtop/p/5717730.html
Copyright © 2011-2022 走看看