Java中socket编程的实现过程（代码实例）-java教程-PHP中文网

首页

Java

java教程

Java中socket编程的实现过程（代码实例）

不言

Sep 25, 2018 pm 03:07 PM

socket编程

本篇文章给大家带来的内容是关于socket编程的实现过程，有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。

1.socket 服务器搭建

实例化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();
			}
		}

	}

}

登录后复制

单例Chatmanage，对所有客户端线程管控处理

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.客户端（创建两个客户端）

客户端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();
            }
            
        }
        
    }

    
    
    
}

登录后复制

ok，简单的sockte服务与客户端完成了

先启动server

在分别启动client

输入结束bye,关闭当前会话

以上是Java中socket编程的实现过程（代码实例）的详细内容。更多信息请关注PHP中文网其他相关文章！

本站声明

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

热AI工具

Undresser.AI Undress

人工智能驱动的应用程序，用于创建逼真的裸体照片

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

免费脱衣服图片

Clothoff.io

AI脱衣机

Video Face Swap

使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸！

显示更多

热工具

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

中文版，非常好用

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

显示更多

热门话题

gmail邮箱登陆入口在哪里

7698

Java教程

1640

CakePHP 教程

1393

Laravel 教程

1287

PHP教程

1229

显示更多

Related knowledge

如何使用Python中的socket编程进行数据通信 Oct 18, 2023 am 11:06 AM

标题：Python中的socket编程及代码示例引言：在现代互联网时代，数据通信无处不在。而Python中的socket编程提供了一种简单而有效的方式来实现网络上的数据传输。本文将介绍如何使用Python的socket模块来进行数据通信，并提供具体的代码示例，帮助读者更好地理解和应用socket编程。一、什么是socket编程？Socket，即套接字，是实现

php如何使用PHP的socket编程功能？ Jun 03, 2023 pm 09:51 PM

PHP是一门广泛应用于Web开发的编程语言，支持许多网络编程应用。其中，Socket编程是一种常用的实现网络通讯的方式，它能够让程序实现进程间的通讯，通过网络传输数据。本文将介绍如何在PHP中使用Socket编程功能。一、Socket编程简介Socket（套接字）是一种抽象的概念，在网络通信中代表了一个开放的端口，一个进程需要连接到该端口，才能与其它进程进行

如何使用C++进行网络编程? Nov 03, 2023 am 11:10 AM

随着互联网的发展，网络编程越来越成为计算机科学的重要组成部分。C++作为一种强大的编程语言，也对网络编程提供了不少支持。本文将介绍如何使用C++进行网络编程。网络编程概述网络编程是指编写程序用于使用计算机网络进行通信的过程。网络编程需要使用网络协议（例如TCP/IP）来进行数据传输。在网络编程中，有两个主要的角色：客户端和服务器。客户端是指发起请求的程序，而

Go语言中的socket编程与服务端编写 May 31, 2023 pm 11:40 PM

随着互联网的快速发展，更多的应用程序需要进行网络通信，而socket编程便成为了一种重要的编程方式。而Go语言则是近年来备受关注的一门编程语言，其在网络编程领域也有着独特的优势。本文将介绍Go语言中的socket编程以及如何编写一个简单的服务端程序。一、socket编程概述Socket是一种在应用层和传输层之间提供的一种抽象层，它允许应用程序通过网络进行通信

PHP入门指南：Socket编程 May 21, 2023 am 08:31 AM

PHP入门指南：Socket编程Socket编程是指在计算机网络上进行通信的一种方式，通过Socket编程，我们可以实现多种类型的网络应用程序，例如聊天室、网络游戏、网络电话等等。在Web开发领域，Socket编程同样具有非常重要的作用，例如实现实时通信、推送消息等功能，通过这种方式，我们可以让Web应用程序呈现出更加丰富多彩的功能和交互性。PHP是一种非常

PHP8.0中的Socket编程 May 14, 2023 am 08:27 AM

随着软件发展和互联网的普及，网络编程越来越重要，而Socket编程是实现网络编程的最基础和底层的功能之一。而随着PHP8.0的发布，我们可以看到PHP引入了一些新的特性和优化。在本文中，我们将探讨在PHP8.0中如何实现Socket编程。什么是Socket编程？Socket是一种用于网络通信的编程方式，可以建立客户端和服务器之间的连接。以Web开发中最常见的

Go语言中的Socket编程详解 Jun 01, 2023 am 08:07 AM

近年来，Go语言（也称为Golang）在程序员社区中越来越受欢迎。Go语言简单易学、高效强大、安全稳定，因此深受开发人员的喜爱。其中，Go语言对Socket编程的支持得到了广泛的关注和赞誉。本文将对Go语言中的Socket编程进行详细介绍，涉及基本原理、使用方法、代码实现等相关内容。一、Socket编程基本原理Socket编程是指在网络编程中使用Socket

如何解决Java中遇到的代码网络编程问题 Jun 30, 2023 pm 04:28 PM

如何解决Java中遇到的代码网络编程问题简介：随着互联网的快速发展，网络编程已经成为开发人员不可或缺的技能之一。Java作为一种广泛使用的编程语言，在网络编程方面也有其独特的优势和挑战。本文将探讨Java中常见的网络编程问题，并提供解决方案。一、Socket连接问题Socket是实现网络通信的基本组件之一，但在使用Socket进行连接时，可能会遇到以下问题：

See all articles

Java中socket编程的实现过程（代码实例）

热AI工具

Undresser.AI Undress

AI Clothes Remover

Undress AI Tool

Clothoff.io

Video Face Swap

热门文章

热工具

记事本++7.3.1

SublimeText3汉化版

禅工作室 13.0.1

Dreamweaver CS6

SublimeText3 Mac版

热门话题