package ceshi;


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


/**
 * TCP通讯，需要建立通路，服务端serversocket监听端口等待信息
 * @author 
 *
 */
public class TCPSocket {


//创建客户端
public static void main1(String[] args) throws Exception {

//指定地址与端口号
Socket so = new Socket("192.168.0.140", 10003);

//获取通路中的输出流，向服务端发送数据
OutputStream os = so.getOutputStream();
//写入数据
os.write("写入数据".getBytes());
so.close();




//如果客户端又返回在这里输出
InputStream is = so.getInputStream();
//缓存
byte[] by = new byte[1024];

int len = is.read(by);//如果服务端没返回消息，read读的is是socket中的流，没有获取到，暂时等待
System.err.println("输出客户端返回的消息"+new String(by,0,len));
}


//创建服务端
public static void main(String[] args) throws Exception {
//创建服务端通路，监听端口
ServerSocket ss = new ServerSocket(10003);
//获取监听到的对象
Socket sk = ss.accept();//阻塞试的，没有内容时，处于等待状态

//获取ip地址
String ip = sk.getInetAddress().getHostAddress();
System.out.println("ip="+ip);

//从客户端中取出输入流、读写数据
InputStream is = sk.getInputStream();
byte[] by = new byte[1024];
int leng = is.read(by);
System.out.println(new String(by, 0, leng));



//接受到客户端的请求后给客户端回消息
OutputStream os = sk.getOutputStream();
os.write("收到客户端请求返回给客户端信息".getBytes());



//关闭客户端
sk.close();

ss.close();//服务器可以不用关闭，因为还有其他的客户端在链接

}
}