java udp 工具类_java基于UDP实现图片群发功能
UDP協(xié)議(用戶數(shù)據(jù)報協(xié)議)是一種不可靠的網(wǎng)絡(luò)協(xié)議，它在通信實例的兩端各建立一個Socket，但是這兩個Socket之間并沒有虛擬鏈路，這兩個Socket只是發(fā)送，接收數(shù)據(jù)報的對象。
UDP的優(yōu)缺點：
1. 因為UDP協(xié)議是面向非連接的協(xié)議，沒有建立連接的過程，因此它的通信效率很高。很適合一些即時性很強的應(yīng)用場景。
2.因為在正式通信前不必與對方先連接，不管對方狀態(tài)就直接發(fā)送，至于對方是否可以收到這些數(shù)據(jù)內(nèi)容，UDP無法控制，所以說UDP是一種不可靠的協(xié)議。
3.傳輸大小限制在64KB以下，這個尤其要注意，在做這個實例的時候，因為沒有考慮到這個，直接傳了一張大圖，結(jié)果找了半天的原因。
Java使用DatagramSocket代表UDP協(xié)議的Socket，它唯一的作用是接收和發(fā)送數(shù)據(jù)報，至于數(shù)據(jù)究竟發(fā)給誰，DatagramSocket并不清楚；具體發(fā)送的目的地是由DatagramPacket自身決定。當(dāng)Client/Server程序使用UDP協(xié)議時，實際上并沒有嚴格的服務(wù)器和客戶端的區(qū)分。通常固定IP地址，固定端口的DatagramSocket對象所在程序被稱為服務(wù)器，因為有固定的IP，端口地址，其他客戶端的數(shù)據(jù)報可以直接發(fā)送到服務(wù)器上。
接收數(shù)據(jù)的DatagramPacket在實例化時無需指定端口和IP地址，給出數(shù)據(jù)數(shù)據(jù)的字節(jié)數(shù)組以及長度即可。然后調(diào)用DatagramSocket的receive()方法等待數(shù)據(jù)報的到來，該方法阻塞線程直到受到一個數(shù)據(jù)報為止。
發(fā)送數(shù)據(jù)的DatagramPacket不同的是，需要給出完整的目的地，包括IP地址和端口，這樣數(shù)據(jù)報才能知道將數(shù)據(jù)發(fā)給誰。當(dāng)服務(wù)器接收到一個DatagramPacket對象后，如果想向該數(shù)據(jù)報的發(fā)送者反饋一些消息，但由于UDP協(xié)議是面向非連接的，所以不知道數(shù)據(jù)報是誰發(fā)送過來的，但程序可以調(diào)用DatagramPacket的getAddress()(返回一個InetAddress對象，發(fā)報的IP地址)，getPort()(返回發(fā)報的端口)和getSocketAddress()(返回一個SocketAddress對象，該對象可以同時代表IP地址和端口)。
實現(xiàn)思路：每個客戶端啟動時都會向服務(wù)端發(fā)送一個字符串，該字符串代表該客戶端已經(jīng)上線，并在服務(wù)端將每個客戶端的發(fā)報地址(即SocketAddress對象)保存在一個Set集合中。當(dāng)點擊任意一個上線的客戶端的發(fā)送圖片按鈕，該圖片數(shù)據(jù)就會被發(fā)送到服務(wù)端上，服務(wù)端遍歷SocketAddress集合，并將圖片數(shù)據(jù)轉(zhuǎn)發(fā)到每個SocketAddress對應(yīng)的客戶端上，就實現(xiàn)了簡單的圖片群發(fā)。具體代碼如下：
客戶端發(fā)送數(shù)據(jù)報的工具類：
public class DatagramUtil
{
public static final int BOADCAST_PORT = 8888;
public static final String DEST_IP = "192.168.1.101";
private static final int DATA_LEN = 50000;
//定義本程序私聊的Socket實例
private DatagramSocket singleSocket = null;
//定義接收網(wǎng)絡(luò)數(shù)據(jù)的字符數(shù)組
byte[] inBuff = new byte[DATA_LEN];
private Handler handler;
//構(gòu)造器，初始化資源
public DatagramUtil(Handler handler) throws Exception
{
this.handler = handler;
//創(chuàng)建用于私聊的DatagramSocket對象
singleSocket = new DatagramSocket();
new ReadSingle().start();
}
//定義單獨用戶發(fā)送消息的方法
public void sendSingle(byte[] msg)
{
try
{
DatagramPacket packet = new DatagramPacket(new byte[0] , 0 , InetAddress.getByName(DEST_IP) , BOADCAST_PORT);
packet.setData(msg);
singleSocket.send(packet);
}
catch (IOException e)
{
e.printStackTrace();
}
}
//不斷地從DatagramSocket中讀取數(shù)據(jù)的線程
class ReadSingle extends Thread
{
byte[] singleBuff = new byte[DATA_LEN];
private DatagramPacket singlePacket = new DatagramPacket(singleBuff , singleBuff.length);
@Override
public void run()
{
while (true)
{
// 讀取Socket中的數(shù)據(jù)
try
{
//讀取Socket中的數(shù)據(jù)
singleSocket.receive(singlePacket);
//處理得到的消息
Message msg = new Message();
msg.what = 0x123;
msg.obj = singleBuff;
handler.sendMessage(msg);
}
catch (IOException e)
{
e.printStackTrace();
if (singleSocket != null)
{
//關(guān)閉該Socket對象
singleSocket.close();
}
}
}
}
}
}
收到服務(wù)端發(fā)來的圖片數(shù)據(jù)時，使用Handler更新UI。
public class MainActivity extends Activity
{
private Button button;
private ImageView img;
private DatagramUtil datagramUtil;
Handler handler = new Handler()
{
@Override
public void handleMessage(Message msg)
{
if (msg.what == 0x123)
{
byte[] result = (byte[]) msg.obj;
img.setImageBitmap(BitmapFactory.decodeByteArray(result , 0 , result.length));
}
}
};
@Override
protected void onCreate(Bundle savedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main_activity);
button = (Button) findViewById(R.id.send_img_all);
img = (ImageView) findViewById(R.id.receiver_img);
try
{
datagramUtil = new DatagramUtil(handler);
sendData(stringYoByte());
}
catch (Exception e)
{
e.printStackTrace();
}
button.setOnClickListener(new View.OnClickListener()
{
@Override
public void onClick(View view)
{
sendData(bitMapToByte());
}
});
}
private void sendData(final byte[] msg)
{
new Thread()
{
@Override
public void run()
{
datagramUtil.sendSingle(msg);
}
}.start();
}
public byte[] bitMapToByte()
{
Bitmap bitmap = BitmapFactory.decodeResource(getResources() , R.drawable.wenqing);
ByteArrayOutputStream byteArray = new ByteArrayOutputStream();
bitmap.compress(Bitmap.CompressFormat.PNG , 100 , byteArray);
bitmap.recycle();
return byteArray.toByteArray();
}
public byte[] stringYoByte()
{
String loginStr = "hello";
return loginStr.getBytes();
}
}
服務(wù)端代碼(運行該Java程序即可)：
public class UDPServer
{
public static final int PORT = 8888;
private static final int DATA_LEN = 50000;
byte[] inBuff = new byte[DATA_LEN];
private DatagramPacket inPacket = new DatagramPacket(inBuff , inBuff.length);
private DatagramPacket outPacket;
private DatagramSocket serverSocket;
private Set socketAddressList = Collections.synchronizedSet(new HashSet());
public void init() throws IOException
{
serverSocket = new DatagramSocket(PORT);
while (true)
{
serverSocket.receive(inPacket);
String result = new String(inBuff , 0 , inBuff.length);
if (result.trim().equals("hello"))
{
socketAddressList.add(inPacket.getSocketAddress());
}
else
{
for (Iterator iterator = socketAddressList.iterator(); iterator.hasNext() ; )
{
SocketAddress socketAddress = iterator.next();
outPacket = new DatagramPacket(inBuff , inBuff.length , socketAddress);
serverSocket.send(outPacket);
}
}
}
}
public static void main(String[] args) throws IOException
{
new UDPServer().init();
}
}
這樣實現(xiàn)了簡單的圖片群發(fā)的效果。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
總結(jié)
以上是生活随笔為你收集整理的java udp 工具类_java基于UDP实现图片群发功能的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
