服务器端
package com.sherlock.nio;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.plaf.synth.SynthSpinnerUI;
public class Test01_Server {
public static void main(String[] args) throws IOException {
//实例化一个 套接字对象 传入 Port端口号[0-65535]
ServerSocket server = new ServerSocket(10000);
//接受客户端的连接 返回一个socket
//专门负责与 指定客户通信
Socket socket = server.accept();
InputStream is = socket.getInputStream();
OutputStream os = socket.getOutputStream();
os.write("欢迎访问中北网站".getBytes());
byte[] arr = new byte[1024];
int len;
len = is.read(arr);
System.out.println("收到客户端消息:"+ new String(arr,0,len));
socket.close();
server.close();
//deom(server);
}
客户端
package com.sherlock.nio;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
public class Test02_Client {
public static void main(String[] args) throws UnknownHostException, IOException {
Socket socket = new Socket("127.0.0.1",10000);
//获取通信io流
InputStream is = socket.getInputStream();
OutputStream os = socket.getOutputStream();
//按照逻辑 去接受发送数据
//收去服务器发送过来的数据
byte[] buf = new byte[1024];
int len;
len = is.read(buf);
System.out.println("从服务器收到消息:"+ new String(buf,0,len));
os.write("我想咨询点事" .getBytes());
socket.close();
}
}