java廣播,java廣播實現

本文目錄一覽：

• 1、java socket，我有客戶端和伺服器的代碼，幫我添加廣播和能多人會話，加分！！代碼如下
• 2、談談你對廣播的理解？
• 3、java里怎麼發廣播呀
• 4、Android系統廣播(Broadcast)註冊，發送，接收流程解析

java socket，我有客戶端和伺服器的代碼，幫我添加廣播和能多人會話，加分！！代碼如下

根據你的改了個！不好意思，其中讀寫的思路稍微有點不同！不過可以做參考！

Server端代碼：

import java.net.*;

import java.io.*;

import java.util.*;

public class TestServer {

ServerSocket s = null;

boolean started = false;//用來監聽伺服器是否啟動！

ListServerReaderWriter clients = new ArrayListServerReaderWriter();//用來存放啟動的客服端

public static void main(String[] args) {

new TestServer().start();

}

public void start() {

try {

s = new ServerSocket(5050);

started = true;

} catch(SocketException e) {

System.out.println(“5050埠正在使用中！！！請關掉相關程序並重新運行伺服器！”);

System.exit(0);

} catch (IOException e) {

e.printStackTrace();

}

int i = 1;

try {

while(started) {

Socket ss = s.accept();

ServerReaderWriter c = new ServerReaderWriter(ss);//建立客服端

System.out.println(“第” + i + “個客服端啟動！”);

++i;

new Thread(c).start();//啟動線程

clients.add(c);

}

} catch (EOFException e) {

System.out.println(“客服端被關閉！”);

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

s.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

class ServerReaderWriter implements Runnable { //建議使用Runnable避免你重寫run方法麻煩！

private Socket s;

private DataInputStream dis = null;//注意賦值，養成好習慣！

private DataOutputStream dos = null;

private boolean bConnected = false;//用於調用連接成功後的run方法

public ServerReaderWriter(Socket s) {

this.s = s;

try {

dis = new DataInputStream(s.getInputStream());

dos = new DataOutputStream(s.getOutputStream());

bConnected = true;

} catch (IOException e) {

e.printStackTrace();

}

}

public void send(String str) {

try {

dos.writeUTF(str);

} catch (IOException e) {

clients.remove(this);

System.out.println(“有客戶退出！”);

}

}

public void run() {

try {

while (bConnected) {

String input = dis.readUTF();

System.out.println(input);

for(int i=0; iclients.size(); ++i) {

ServerReaderWriter c = clients.get(i);

c.send(input);

}

}

} catch(SocketException e) {

System.out.println(“一個客服端已關閉,請勿再像他發送信息！”);

} catch (EOFException e) {

System.out.println(“謝謝使用！”);

}catch (IOException e) {

e.printStackTrace();

} finally {

try {

if (dis != null) {

dis.close();

}

if (dos != null) {

dos.close();

}

if (s != null) {

s.close();

s = null;

}

//clients.clear();

} catch (IOException e1) {

e1.printStackTrace();

}

}

}

}

}

Client端代碼：

import java.io.*;

import java.net.*;

import java.awt.*;

import java.awt.event.*;

public class TestClient extends Frame { //用到Frame生產界面比較直觀

Socket s = null;

DataOutputStream dos = null;

DataInputStream dis = null;

private boolean bConnected = false;

TextField tfText = new TextField();

TextArea taContent = new TextArea();

Thread tRecv = new Thread(new ClientReaderWriter());

public static void main(String[] args){

new TestClient().launchFrame();

}

public void launchFrame() {

this.setSize(300, 300); //設置客服端窗口格式

this.setLocation(400, 300);

add(tfText, BorderLayout.SOUTH);

add(taContent, BorderLayout.NORTH);

this.pack();

this.addWindowListener(new WindowAdapter() { //監聽窗口關閉事件

public void windowClosing(WindowEvent arg0) {

disconnect();

System.exit(0);

}

});

tfText.addActionListener(new TFListener());

setVisible(true);

connect();

tRecv.start();

}

public void connect() {

try {

s = new Socket(“127.0.0.1”, 5050); //依據自己的伺服器，我這裡用的localhost

dos = new DataOutputStream(s.getOutputStream());

dis = new DataInputStream(s.getInputStream());

System.out.println(“連接伺服器！”);

bConnected = true;

} catch(ConnectException e) {

System.out.println(“請檢查伺服器是否啟動！”);

try {

Thread.sleep(1000);

} catch (InterruptedException e1) {

e1.printStackTrace();

}

System.exit(0);

}

catch (UnknownHostException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

public void disconnect() {

try {

dos.close();

dis.close();

s.close();

} catch (IOException e) {

e.printStackTrace();

}

}

private class TFListener implements ActionListener {

public void actionPerformed(ActionEvent e) {

String str = tfText.getText().trim();

tfText.setText(“”);

try {

dos.writeUTF(str);

if(str.equals(“bye”)){

System.exit(0);

}

dos.flush();

} catch (IOException e1) {

e1.printStackTrace();

}

}

}

class ClientReaderWriter implements Runnable {

public void run() {

try {

while(bConnected) {

String input = dis.readUTF();

taContent.setText(taContent.getText() + input +’\n’);

}

} catch (SocketException e) {

System.out.println(“輕輕的我走了！Bye-bye!”);

} catch (EOFException e) {

System.out.println(“我斷網了，再見!”);

}

catch (IOException e) {

e.printStackTrace();

}

}

}

}

談談你對廣播的理解？

廣播就是用來發送/接收一系列通知的組件，它是四大組件之一，常用於進程間的通信。

低耦合高內聚：如果兩個組件之間需要通信的話，可以通過獲取組件之間的實例，但是這種方法無疑增加了耦合，不是很好，而使用廣播，可以不需要獲取對方的實例就能拿到想到的數據，當然還有更方便的事件匯流排機制，這裡只是舉個例子。它不僅可以使用在組件之間的通信，還有使用在進程間通信，程序保活等。

a.有序廣播

b.無序廣播

c.普通廣播

d.粘性廣播

e.本地廣播

f.系統廣播

首先需要一個廣播接收器

然後註冊廣播， 註冊可分為靜態和動態註冊：

1.動態註冊：

這裡要注意的是在程序銷毀之前要解綁該廣播，防止造成內存泄漏。

2.靜態註冊：

靜態註冊是通過在xml中完成的

最後就是發送廣播：

這裡需要特別說明一下本地廣播，其他的廣播可以存在被人攔截或者被人攻擊的情況，所以安全性不是很高，所以就出了本地廣播，這套機制只能接收應用程序內部的廣播，所以就不存被人攔截或者攻擊的情況。

廣播的發送不變。

a.廣播不會發送消息給已經停止的應用

b.Android 7.0屏蔽了某些廣播事件,如: 後台程序無法監聽網路狀態,不允許靜態註冊,防止應用無節操地惡意喚醒

c.某些三方ROM(如:MUI/EMUI)也限制了某些廣播事件,如:華為 EMUI 需要設置允許當前程序開機啟動才允許監聽 BOOT_COMPLETED

d.onReceiver()方法不要執行特別耗時的操作,耗時操作可以放到Service組件中

e.LocalBroadcastManager 不會有應用劫持廣播信息的情況 ,只有 BroadcastManager 才會出現 ,所以 如果不是跨進程的話可以用 LocalBroadcastManager 完全替代 Broadcastreceive

是通過binder實現的，這個暫時不了解，後續會繼續研究。

1.靜態廣播和動態廣播哪一個先接收到？

答：動態優先靜態，具體原因可以翻看ActivityManagerService(…/sdk/sources/android-xx/com/android/server/am/ActivityManagerService.java)的源碼，可以根據sendBroadcast去一步一步的往下跟，最後你會發現，先遍歷動態廣播再靜態廣播，所以動態廣播優先於靜態。

java里怎麼發廣播呀

java里怎麼發廣播

public void onReceive(Context context,Intent intent){

Intent intent = new Intent(context,XxxService.class);

context.startService(intent);

}

Intent intent = new Intent();

intent.setAction(“…”);

Context.sendBroadcast(intent);

Android系統廣播(Broadcast)註冊，發送，接收流程解析

以下廣播簡稱Broadcast

   是Android四大組件之一，在四大組件的另外兩個組件 和 擁有發送和接收廣播的能力。Android 是在 進程間通信機制的基礎上實現的，內部基於消息發布和訂閱的事件驅動模型，廣播發送者負責發送消息，廣播接收者需要先訂閱消息，然後才能收到消息。 進程間通信與 的區別在於：

   有三種類型

   存在一個註冊中心，也可以說是一個調度中心，即 。廣播接收者將自己註冊到 中，並指定要接收的廣播類型；廣播發送者發送廣播時，發送的廣播首先會發送到 ， 根據廣播的類型找到對應的 ，找到後邊將廣播發送給其處理。

   這裡以普通廣播為例子， 接收者有兩種註冊方式，一種是 ，一種是 ：

（廣播的發送分為 兩種，這裡針對有序的廣播） 中的android:priority=””和 中的IntentFilter.setPriority(int)可以用來設置廣播接收者的優先順序，默認都是0 , 範圍是[-1000, 1000]，值越大優先順序越高，優先順序越高越早收到。

   在相同優先順序接收同個類型廣播時， 的廣播接收器比 的廣播接收者更快的接收到對應的廣播，這個之後會進行分析。

   註：以下源碼基於rk3399_industry Android7.1.2

   的流程可分為 ， 和 三個部分，這裡依次分析下

   在Android系統的 機制中，前面提到， 作為一個註冊和調度中心負責註冊和轉發 。所以 的註冊過程就是把它註冊到 的過程。

   這裡我們分析 廣播的過程， 和 有一個共同的父類 ，所以它們對應的註冊過程其實是調用 ，接下來我們按照流程逐步分析調用流程的源碼。

frameworks/base/core/java/android/content/ContextWrapper.java

   在之前的 Android應用程序啟動入口ActivityThread.main流程分析 分析過，在我們啟動 Activity 時會創建一個 對象，然後通過 傳給我們啟動的 ，其內部就會將該對象賦值給 ； 的 方法也是類似的賦值流程，這裡放個簡易的源碼應該更好理解

   可以看到最後都會將生成的 對象賦值給對應的

對象。接下來繼續分析 ， 即 函數。

/frameworks/base/core/java/android/app/ContextImpl.java

   這裡我們首先看下如何將廣播接收者 封裝成一個 介面的 本地對象

/frameworks/base/core/java/android/app/LoadedApk.java

   每一個註冊過廣播接收者的 或 組件在font color=’Crimson’ LoadedApk /font類中都有個對應的 對象，該對象負責將 與 組件關聯起來。這些對象，以關聯的 作為關鍵字保存在一個 中。之後對應的 又以 的 作為關鍵字保存在 的成員變數 對象中。最後通過 對應的 方法獲得其 介面的 本地對象。之後再回到 註冊方法內，將 對象發給 進行註冊。

/frameworks/base/core/java/android/app/ActivityManagerNative.java

/frameworks/base/services/core/java/com/android/server/am/ActivityManagerService.java

   在的 或 註冊一個 時，並不是將其註冊到font color=’OrangeRed’AMS/font中，而是將與它關聯的font color=’OrangeRed’InnerReceiver/font對象註冊到font color=’OrangeRed’AMS/font中，當font color=’OrangeRed’AMS/font接收到廣播時，會根據 在內部找到對應的font color=’OrangeRed’InnerReceiver/font對象，然後在通過這個對象將這個廣播發送給對應的 處理。

   註冊過程這邊畫了一個簡單的流程圖:

   font color=’OrangeRed’Broadcast/font的發送過程可簡單描述為以下幾個過程：

frameworks/base/core/java/android/content/ContextWrapper.java

/frameworks/base/core/java/android/app/ContextImpl.java

/frameworks/base/core/java/android/app/ActivityManagerNative.java

/frameworks/base/services/core/java/com/android/server/am/ActivityManagerService.java