이 기사의 내용은 소켓 프로그래밍의 구현 과정에 관한 것입니다. 특정 참고 가치가 있으므로 도움이 필요한 친구에게 도움이 되기를 바랍니다.
1.socket 서버 구축
소켓 서버를 인스턴스화하고 루프에서 요청을 얻습니다
package com.orange.util; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.util.Timer; import java.util.TimerTask; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; /** * socket服务器 * * @author Chengjq * */ public class SocketServer { public static int count = 0; public static void main(String[] args) { // TODO 自动生成的方法存根 int port = 4404; // 首先直接创建serversocket ServerSocket serverSocket = null; Socket socket = null; try { serverSocket = new ServerSocket(port); System.out.println("启动socketServer成功,等待客户端的连接"); while (true) { socket = serverSocket.accept(); System.out.println("有新的客户端请求连接"); SocketThread st = new SocketThread(socket); st.start(); ChatManager.getChatManager().add(st); //启动定时任务,如果10s内没有进程 /*Runnable runnable = new Runnable() { int clientNum = 0; public void run() { // task to run goes here clientNum = ChatManager.getChatManager().vector.size(); System.out.println("剩余客户端数量:"+clientNum); if(clientNum ==0 ){ System.out.println("连接超时,或者无客户端连接,关闭serverSocket"); //关闭socket //..... } } }; ScheduledExecutorService service = Executors .newSingleThreadScheduledExecutor(); // 第二个参数为首次执行的延时时间,第三个参数为定时执行的间隔时间 service.scheduleAtFixedRate(runnable, 2, 10, TimeUnit.SECONDS); */ } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { System.out.println("serverSocket已超时"); try { socket.close(); serverSocket.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
SocketThread 클래스는 다중 스레드 통신을 구현합니다.
package com.orange.util; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; /** * SocketThread实现多线程通信 * * @author Administrator * */ public class SocketThread extends Thread { ServerSocket serverSocket = null; Socket socket = null; public SocketThread(ServerSocket serverSocket,Socket socket) { super(); this.serverSocket = serverSocket; this.socket = socket; } public SocketThread(Socket socket) { super(); this.socket = socket; } public void out(String out) { try { socket.getOutputStream().write(out.getBytes("utf-8")); } catch (IOException e) { e.printStackTrace(); } } public void publish(String out){ ChatManager.getChatManager().publish(this, out); } @Override public void run() { // TODO Auto-generated method stub BufferedReader socketIn = null; PrintWriter socketOut = null; String inMess = null; try { socketIn = new BufferedReader(new InputStreamReader(socket.getInputStream())); socketOut = new PrintWriter(socket.getOutputStream()); while (true) { inMess = socketIn.readLine(); publish(inMess); if("bye".equals(inMess)){ ChatManager.getChatManager().remove(this); } } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { try { System.out.println("已结束当前会话"); socketOut.close(); socketIn.close(); socket.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
단일 인스턴스 Chat관리, 모든 클라이언트 스레드를 제어하고 처리합니다
package com.orange.util; import java.util.Vector; public class ChatManager { // 实现单例化 private ChatManager() { }; private static final ChatManager cm = new ChatManager(); public static ChatManager getChatManager() {// 返回值为ChatManager return cm; } // 单例化完成 Vector<SocketThread> vector = new Vector<SocketThread>(); public void add(SocketThread st) {// 为当前集合添加SocketThread对象 vector.add(st); } public void remove(SocketThread st) {// 当前客户端关闭连接 vector.remove(st); } public void removeall() {// 关闭所有连接 for (int i = 0; i < vector.size(); i++) {// 遍历所有的线程 SocketThread csChatSocket = vector.get(i); if(csChatSocket!=null){ vector.remove(csChatSocket); } } } // 某一个线程向其他的客户端发送信息 public void publish(SocketThread st, String out) { for (int i = 0; i < vector.size(); i++) {// 遍历所有的线程 SocketThread csChatSocket = vector.get(i); if (csChatSocket != st)// 判断不是当前线程就发送此消息 csChatSocket.out(out + "\n"); } } // 向当前线程发信息 public void publish_present(SocketThread st, String out) { st.out(out + "\n"); } }
이 시점에서, 서버 구축이 완료되었습니다
2. 클라이언트(클라이언트 2개 생성)
클라이언트 1(지정된 서버의 말을 듣고, 콘솔을 통해 메시지를 입력하여 서버와 클라이언트, 클라이언트 간 통신)
package com.orange; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.net.UnknownHostException; /** * 客户端1 * @author Chengjq * */ public class SocketClient1 { @SuppressWarnings("static-access") public static void main(String[] args) { try { //初始化客户端 Socket socket = new Socket("127.0.0.1", 4404); BufferedReader readline = new BufferedReader(new InputStreamReader(System.in)); //获取输出打印流 PrintWriter socketOut = new PrintWriter(socket.getOutputStream()); String outTemp = null; System.out.println("开始准备向服务器端发起请求---\n自己:"); // 已启动连接socket服务器,准备实时接收来自其他客户端的消息 GetMess getMess = new GetMess(socket); getMess.start(); // 通过控制台发送消息给其他客户端,以“bye”为结束语 while ((outTemp = readline.readLine()) != null) { //发送信息 socketOut.println(outTemp); socketOut.flush(); if("bye".equals(outTemp)){ break; } } getMess.currentThread().interrupt(); //依次关闭各种流 readline.close(); socketOut.close(); socket.close(); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
클라이언트 2
package com.orange; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.net.UnknownHostException; public class SocketClient2 { @SuppressWarnings("static-access") public static void main(String[] args) { try { //初始化客户端 Socket socket = new Socket("127.0.0.1", 4404); BufferedReader readline = new BufferedReader(new InputStreamReader(System.in)); //获取输出打印流 PrintWriter socketOut = new PrintWriter(socket.getOutputStream()); String outTemp = null; System.out.println("开始准备向服务器端发起请求---\n自己:"); // 已启动连接socket服务器,准备实时接收来自其他客户端的消息 GetMess getMess = new GetMess(socket); getMess.start(); // 通过控制台发送消息给其他客户端,以“bye”为结束语 while ((outTemp = readline.readLine()) != null) { //发送信息 socketOut.println(outTemp); socketOut.flush(); if("bye".equals(outTemp)){ break; } } getMess.currentThread().interrupt(); //依次关闭各种流 readline.close(); socketOut.close(); socket.close(); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
GetMess(다른 클라이언트로부터 메시지를 가져와 표시하는 멀티스레드 처리)
package com.orange; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.Socket; public class GetMess extends Thread { Socket socket = null; public GetMess(Socket socket) { super(); this.socket = socket; } @Override public void run() { // TODO Auto-generated method stub BufferedReader socketIn = null; try { InputStream is = socket.getInputStream(); InputStreamReader isr = new InputStreamReader(is); socketIn = new BufferedReader(isr); String inTemp = null; while(true){ inTemp = socketIn.readLine(); if(inTemp != null && !"bye".equals(inTemp) ){ System.out.println("好友:\n"+inTemp); }else{ System.out.println("好友:\n已下线,关闭当前回话"); break; } } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { try { Thread.currentThread().interrupt(); socketIn.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
좋아요, 간단한 sockte 서비스와 클라이언트가 완성되었습니다
서버를 먼저 시작하고
클라이언트를 별도로 시작하세요
현재 세션을 닫으려면 종료를 입력하세요
위 내용은 Java에서 소켓 프로그래밍 구현 프로세스(코드 예)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!