package Net;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
public class UserSocket {
public static void main(String[] args) throws IOException {
//连接服务端(ip加端口)
//连接成功就返回socket对象
Socket socket = new Socket(InetAddress.getLocalHost(),9999);
System.out.println("反回了"+socket.getClass());
OutputStream outputStream = socket.getOutputStream();
outputStream.write("hello,server".getBytes());
socket.shutdownOutput();
InputStream inputStream = socket.getInputStream();
int readLine=0;
byte []bytes=new byte[1024];
while((readLine=inputStream.read())!=-1){
System.out.println(new String(bytes,0,readLine));
}
outputStream.close();
inputStream.close();
socket.close();
System.out.println("客户走了");
}
}
package Net;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerSocket1 {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket=new ServerSocket(9999);
System.out.println("等待监听");
//有用户连接就返回一个对象
Socket socket= serverSocket.accept();
System.out.println("socket="+socket.getClass());
byte []bytes=new byte[1024];
InputStream inputStream = socket.getInputStream();
int readLine=0;
while((readLine=inputStream.read(bytes))!=-1) {
System.out.println(new String(bytes, 0, readLine));
}
OutputStream outputStream = socket.getOutputStream();
outputStream.write("hello,client".getBytes());
socket.shutdownOutput();
outputStream.close();
inputStream.close();
socket.close();
serverSocket.close();
}
}