package tcp; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; public class Server { /*创建ServerSocket服务 * 服务端必须对外提供一个端口。否则客户端无法连接 * 获取连接过来的客户端对象 * 通过客户端对象获取socket流读取客户端发来的数据 * 并打印在控制台上 * 关闭资源关闭客户端,关闭服务端 * */ public static void main(String[] args) throws Exception { ServerSocket ss=new ServerSocket(10005); Socket accept = ss.accept();//获取对象 InputStream inputStream = accept.getInputStream(); byte[] buf=new byte[1024]; int len=inputStream.read(buf); String text=new String(buf,0,len); System.out.println(text); accept.close(); ss.close(); } }
package tcp; import java.io.IOException; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class Cilent { /*创建Socket服务。 * 连接socket主机 * 2.如果连接成功调用输入输出。说明数据通道已建立 * 该通道是socket流,底层建立好的。想要输入输出流对象, * 可以找socket对象 * 可以使用getOutputStream getinputStream * 3.使用输出流。将数据写出 * 4.关闭资源 * */ public static void main(String[] args) throws Exception, Exception { //创建Socket服务 Socket socket=new Socket("127.0.0.1", 10005); OutputStream outputStream = socket.getOutputStream(); outputStream.write("tcp.............".getBytes()); } }