基于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();
        }
    }
}
上一篇:【MySQL】随机获取数据的方法,支持大数据量


下一篇:MVVM架构~Knockoutjs系列之对象与对象组合