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 소켓 프로그래밍을 서버 측 PHP 소켓과 클라이언트 측 PHP 소켓으로 나누는 이유는 무엇인가요?
위 내용은 Java는 서버 측 serverSocket 및 클라이언트 측 소켓을 생성합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!