TCP收发测试

接收

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Tcp {

 /*
  * TCP接收
  */
    public static void main(String[] args) throws Exception{
        try {
            System.out.println("12345678");
            int port = 8081;
            //创建服务器端的Socket对象(ServerSocket)
            ServerSocket serverSocket = new ServerSocket(port);
            //serverSocket.bind(new InetSocketAddress(port));
            while (true) {
            //监听客户端连接，返回一个Socket对象
            Socket socket = serverSocket.accept();
            //设置阻塞的超时时间
            //socket.setSoTimeout(5000);
            //输出流
            OutputStream output = socket.getOutputStream();
            //获取输入流，读数据，并把数据显示在控制台
            InputStream input = socket.getInputStream();
            //打印连接IP
            String IP = serverSocket.getInetAddress().getHostAddress();
            System.out.println(IP + "......connected");
            
            int i = 0;
            while (socket.isConnected()) {
                byte[] b = new byte[1024];
                int len = input.read(b) + 1;
                
                // 把一个字节数组str从0取到len，取出来之后转换成String类型
                String str = new String(b, 0, len);
                System.out.println("数据为" + str);
                output.write(str.getBytes());
                //output.write("okok".getBytes());//可删
                i++;
                if(i > 10) {
                    break;
                }
            
            }
            socket.close();
            //serverSocket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

发送

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
/*
 * 客户端向服务器发送数据
 */
public class TcpSend {
 
 public static void main(String[] args) throws Exception {
        //接受控制台数据的输入流
        BufferedReader buff=null;
        //定义保存服务器地址的对象【String】
        InetAddress serverip=null;
        //定义连接服务器的端口号
        int serverport=38700;
        //定义创建客户端对象的Socket
        Socket client=null;
        //定义发送信息的输出流对象
        OutputStream out=null;
        //定义保存被发送的数据
        String info=null;
        //返回包含有本机IP地址的InetAddress对象,花生壳透传公网IP
        serverip=InetAddress.getByName("454585x8l0.qicp.vip");
        System.out.println("接收方： " + serverip.getHostName());
        System.out.println("接收IP： " + serverip.getHostAddress());
        //Socket(InetAddress address,int prot)---创建流套接字并将其连接到指定IP地址的指定端口号
        client=new Socket(serverip,serverport);
        // getOutputStream()---返回客户端的输出流。【与服务器的输入流连接】
        out=client.getOutputStream();
        for(int i=0;i<5;i++) {
            System.out.println("请输入发送的数据");
                buff=new BufferedReader(new InputStreamReader(System.in));
            info=buff.readLine();
            out.write(info.getBytes());
        }
        
        out.close();
        buff.close();
        client.close();
    }
    
}