频道栏目
首页 > 资讯 > 其他 > 正文

Java基于UDP 实现 Socket中的多客户端通信

17-04-17        来源:[db:作者]  
收藏   我要投稿

Java基于UDP 实现 Socket中的多客户端通信:Java基于UDP 怎么实现 Socket中的多客户端通信呢?希望下面的文章对大家有所帮助。

package com.learn;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

/*
 * 实现基于UDP的用户登录
 */
public class UDPServer {
    public static void main(String[] args) {

        try {
            /*
             * 接收客户端发送的数据
             */
            // 1.创建服务器端 datagramsocket
            DatagramSocket server = new DatagramSocket(8888);
            // 2.接收客户端发送的数据
            System.out.println("***服务器端已启动,等待客户端上线***");

            while (true) {
                UDPServerThread st = new UDPServerThread(server);
                st.start();
            }

        } catch (SocketException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

客户端

package com.learn;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPServerThread extends Thread {
    DatagramSocket socket;

    public UDPServerThread(DatagramSocket socket) {
        this.socket = socket;
    }

    public void run() {
        // 创建数据报,用于接收客户端发送的数据
        byte[] bytes = new byte[1024];
        DatagramPacket packet = new DatagramPacket(bytes, bytes.length);

        try {
            socket.receive(packet);// 此方法会在接收到数据之前一直阻塞
            // 读取数据
            String info = new String(bytes, 0, packet.getLength());
            System.out.println("我是服务器,客户端发来数据说:" + info);

            /*
             * 响应客户端发来的消息
             */

            // 1.定义客户端的地址,端口号,数据
            InetAddress address = packet.getAddress();
            int port = packet.getPort();
            byte[] data = "欢迎上线".getBytes();
            // 2.创建数据报,包含响应的数据信息
            packet = new DatagramPacket(data, data.length, address, port);
            // 3.响应客户端,发送数据
            socket.send(packet);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }
}

 

相关TAG标签
上一篇:Java设计模式之责任链模式
下一篇:Android 开发 Tip 5 -- View xxx not attached to window manager
相关文章
图文推荐

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站