华尔思线上版本库

hxb

2022-03-27 cc6023291bc94a229b53d7c2d83bf2b39bbfa9a0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
package com.hdl.sdk.socket; 
 
import com.hdl.sdk.socket.client.IClient; 
 
import java.net.DatagramSocket; 
import java.net.InetSocketAddress; 
import java.net.SocketException; 
import java.util.concurrent.ConcurrentHashMap; 
 
/** 
 * Created by Tong on 2021/10/19. 
 * 计划参考generic-pool、Commons Pool进行完善 
 */ 
public class SocketPool { 
 
    private final ConcurrentHashMap<String, IClient> mPool; 
    private final ConcurrentHashMap<String, DatagramSocket> mUdpClientPool; 
 
    private SocketPool() { 
        mPool = new ConcurrentHashMap<>(); 
        mUdpClientPool = new ConcurrentHashMap<>(); 
    } 
 
    private static final SocketPool instance = new SocketPool(); 
 
    public static SocketPool getInstance() { 
        return instance; 
    } 
 
    public void clear() { 
        mPool.clear(); 
        mUdpClientPool.clear(); 
    } 
 
    public synchronized DatagramSocket getUdpSocket(InetSocketAddress address) throws SocketException { 
        DatagramSocket socket; 
        final String key = address.toString(); 
        if (mUdpClientPool.containsKey(key)) { 
            socket = mUdpClientPool.get(key); 
            if (socket != null && !socket.isClosed()) { 
                return socket; 
            } else { 
                socket = new DatagramSocket(address); 
            } 
        } else { 
            socket = new DatagramSocket(address); 
        } 
        mUdpClientPool.put(address.toString(), socket); 
        return socket; 
    } 
}