import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.PrintWriter;import java.net.ServerSocket;import java.net.Socket;/** * 服务端 * @author Administrator * */public class Server { public static void main(String[] args) throws IOException { //创建一个服务器端socket,指定绑定的端口号,并监听此端口 ServerSocket serverSocket = new ServerSocket(8888); //调用accept()方法开始监听,等待客户端的连接 System.out.println("**********服务器即将启动,等待客户端的连接*************"); Socket socket = serverSocket.accept(); //获取输入流,并读取客户端信息 InputStream inp = socket.getInputStream(); //把字节流转换成字符流 InputStreamReader isr = new InputStreamReader(inp); //为字符流增加缓冲区 BufferedReader bfr = new BufferedReader(isr); String info = null; while((info=bfr.readLine())!=null){//循环读取数据 System.out.println("客户已连接,报文内容:"+info); } socket.shutdownInput();//关闭输入流 //向客户端传递的信息 OutputStream ots = socket.getOutputStream(); PrintWriter pw = new PrintWriter(ots); pw.write("欢迎使用"); pw.flush(); //关闭资源 pw.close(); ots.close(); bfr.close(); isr.close(); inp.close(); socket.close(); serverSocket.close(); } }
import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.PrintWriter;import java.net.Socket;import java.net.UnknownHostException;/** * 客户端 * @author Administrator * */public class Client { public static void main(String[] args) { try { //创建一个客户端socket Socket socket = new Socket("localhost",8888); //向服务器端传递信息 OutputStream ots = socket.getOutputStream(); PrintWriter pw = new PrintWriter(ots); pw.write("服务器你好!"); pw.flush(); //关闭输出流 socket.shutdownOutput(); //获取服务器端传递的数据 InputStream is = socket.getInputStream(); InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); String info = null; while((info=br.readLine())!=null){ System.out.println("服务器返回报文:"+info); } //关闭资源 br.close(); isr.close(); is.close(); pw.close(); ots.close(); socket.close(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }
服务器端输出:
**********服务器即将启动,等待客户端的连接*************客户已连接,报文内容::服务器你好!
客户端输出:
服务器返回报文:欢迎使用
相关文章:
php socket 编程 为什么要分 服务端 php socket 和 客户端 php socket?
Atas ialah kandungan terperinci Java创建服务器端serverSocket和客户端socket. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!