黑马程序员技术交流社区

标题: 黑马程序员 TCP通讯 [打印本页]

---

作者: Wchunwei    时间: 2015-1-1 13:54
标题: 黑马程序员 TCP通讯
package FromScreen;

import java.io.Serializable;
import java.util.Scanner;

public class FromScreen implements Serializable {
       
        /**
         *
         */
        private static final long serialVersionUID = 3552585161044065350L;
        private Scanner sc = new Scanner(System.in);
       
        public String getStringFromScreen()   //从控制台得到用户输入数据
        {
                return sc.nextLine();
        }
       
}

客户端：
package FromScreen;
import java.io.*;
import java.net.*;
public class tcpClient {
public static void main(String[] args) throws IOException{
Socket ss=new Socket("127.0.0.1",8888);
System.out.println("Socket:"+ss);
try{
        //套接字建立成功，建立I/O流进行通信
        DataInputStream dis=new DataInputStream(ss.getInputStream());
        DataOutputStream dos=new DataOutputStream(ss.getOutputStream());
        FromScreen fs=new FromScreen();
        for(int i=0;i<=100;i++)
        {
                dos.writeUTF("tcoClient   "+fs.getStringFromScreen());
                dos.flush();
                //if(fs.getStringFromScreen().equals("end")) break;
                System.out.println(dis.readUTF());
        }
        dos.writeUTF("end");               
        dos.flush();                               
        dos.close();
        dis.close();
   }finally{
         ss.close();
      }
    }
}
服务器端：
package FromScreen;
import java.io.*;
import java.net.*;
public class tcpServer {
        public static final int PORT=8888;
        public static void main(String[] args) throws IOException{
            //建立ServerSocket
            ServerSocket s=new ServerSocket(PORT);
            System.out.println("ServerSocket:"+s);
            try{
        Socket ss=s.accept();
        System.out.println("Socket accept:"+ss);
        FromScreen fs=new FromScreen();
        try
        {
          DataInputStream dis=new DataInputStream(ss.getInputStream());
          DataOutputStream dos=new DataOutputStream(ss.getOutputStream());
                    //在循环中，与客户机通信
                while(true)
                {
            String str=dis.readUTF();        //从客户机中读数据
                if(str.equals("end"))break;        //当读到end时，程序终止
                   System.out.println(str);
                       dos.writeUTF("tcpServer   :"+fs.getStringFromScreen());        //向客户机中写数据
                }
                dos.close();
                dis.close();
            }finally{
                ss.close();
            }
            }finally{
        s.close();
            }
        }
}
Tcp这个地方感觉与UDP好像啊，有点复杂

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2