java– 我有两个Android应用程序,一个可以通过LAN发送特定的IP和其他应用程序接收,但我想通过局域网广播字符串?

java– 我有两个Android应用程序,一个可以通过LAN发送特定的IP和其他应用程序接收,但我想通过局域网广播字符串?,第1张

概述我想通过LAN广播字符串,但是当我将客户端代码中的服务器IP更改为255.255.255.255时,它不会广播.如何通过LAN广播字符串?我应该在客户端代码中做什么,以便不同IP的所有侦听端口可以同时接收字符串.我发送字符串的客户端或代码是:publicclassMainActivityextendsActivity{

我想通过LAN广播字符串,但是当我将客户端代码中的服务器IP更改为255.255.255.255时,它不会广播.如何通过LAN广播字符串?我应该在客户端代码中做什么,以便不同IP的所有侦听端口可以同时接收字符串.

我发送字符串的客户端或代码是:

public class MainActivity extends Activity {    private Socket socket;    private static final int SERVERPORT = 6000;    private static final String SERVER_IP = "192.168.1.10";    @OverrIDe    public voID onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentVIEw(R.layout.activity_main);             new Thread(new ClIEntThread()).start();    }public voID onClick(VIEw vIEw) {        try {            EditText et = (EditText) findVIEwByID(R.ID.EditText01);            String str = et.getText().toString();            PrintWriter out = new PrintWriter(new BuffereDWriter(                new OutputStreamWriter(socket.getoutputStream())), true);            out.println(str);        } catch (UnkNownHostException e) {            e.printstacktrace();        } catch (IOException e) {            e.printstacktrace();        } catch (Exception e) {            e.printstacktrace();        }    }    class ClIEntThread implements Runnable {    @OverrIDe        public voID run() {            try {                InetAddress serverAddr = InetAddress.getByname(SERVER_IP);                socket = new Socket(serverAddr, SERVERPORT);            } catch (UnkNownHostException e1) {                e1.printstacktrace();            } catch (IOException e1) {                e1.printstacktrace();            }        }    }}

我的服务器或接收字符串的代码是:

public class MainActivity extends Activity {    private ServerSocket serverSocket;    Handler updateConversationHandler;    Thread serverThread = null;    private TextVIEw text;    public static final int SERVERPORT = 6000;    @OverrIDe    public voID onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentVIEw(R.layout.activity_main);        text = (TextVIEw) findVIEwByID(R.ID.text2);        updateConversationHandler = new Handler();        this.serverThread = new Thread(new ServerThread());        this.serverThread.start();    }    @OverrIDe    protected voID onStop() {        super.onStop();        try {            serverSocket.close();        } catch (IOException e) {            e.printstacktrace();        }    }    class ServerThread implements Runnable {        public voID run() {            Socket socket = null;            try {                serverSocket = new ServerSocket(SERVERPORT);            } catch (IOException e) {                e.printstacktrace();            }            while (!Thread.currentThread().isInterrupted()) {                try {                    socket = serverSocket.accept();                    CommunicationThread commThread = new CommunicationThread(socket);                    new Thread(commThread).start();                } catch (IOException e) {                    e.printstacktrace();                }            }        }    }    class CommunicationThread implements Runnable {        private Socket clIEntSocket;        private BufferedReader input;        public CommunicationThread(Socket clIEntSocket) {            this.clIEntSocket = clIEntSocket;            try {                this.input = new BufferedReader(new inputStreamReader(this.clIEntSocket.getinputStream()));            } catch (IOException e) {                e.printstacktrace();            }        }        public voID run() {            while (!Thread.currentThread().isInterrupted()) {                try {                    String read = input.readline();                    updateConversationHandler.post(new updateUIThread(read));                } catch (IOException e) {                    e.printstacktrace();                }            }        }    }    class updateUIThread implements Runnable {        private String msg;        public updateUIThread(String str) {            this.msg = str;        }        @OverrIDe        public voID run() {            text.setText(text.getText().toString()+"ClIEnt Says: "+ msg + "\n");        }    }}

解决方法:

Socket是一个TCP套接字. TCP无法进行广播.如果要使用TCP,则无法广播,必须为每个客户端打开一个连接,并分别通过每个连接发送数据.

DatagramSocket是一个UDP套接字. UDP可以进行广播.但是,需要注意的是UDP并不能保证您的消息实际到达.为了保证您的消息到达,您必须实现某种确认/重试协议,但如果您这样做,您也可以使用TCP,因为它就是它的功能.

编辑:另一个问题和我在下面评论中的回答. OP写道:

then how i’ll get the IP’s of Listening devices in LAN in order to make connection separately?

这里的主题是设备或服务发现,这是一个并不罕见的挑战.有很多选择.以下是一些,没有特别的顺序:

>在客户端设备的配置中指定服务器IP地址,并让它们连接到您.
>在服务器设备的配置中指定客户端IP地址列表,并将其连接到所有客户端IP地址.
>实现某种UDP发现协议,其中您通过UDP广播发现请求,设备使用有关其IP地址等的信息进行响应.同样的警告如上.
>让您的服务器广播UDP消息,宣布其存在及其IP地址,让您的客户端监听这些消息并建立到服务器的TCP连接.同样的警告如上.
>查看现有的服务发现协议,例如jmdns.sourceforge.net(与Bonjour / zeroconf兼容).这实际上是一个非常普遍的问题,并且存在许多解决它的协议.
>让您的服务器扫描其子网中的所有IP,并尝试与每个IP建立TCP连接.非常耗时,但可能是合适的.

选项1-2是最简单的实现,但需要用户手动配置.

选项3-5有一个共同的主题:通过使用UDP及其广播功能自动交换配置信息,避免手动配置要求.使用该信息建立TCP连接,然后使用TCP进行可靠的数据传输.请记住,UDP广播的范围受限于子网,因此您无法使用基于广播的发现来发现其他LAN上的计算机 – 因为您必须使用基于TCP的注册执行某种中央服务注册表.一个着名的注册服务器.

选项6避免了手动配置,代价是极差的发现性能和潜在的系统资源使用率高.选项3-5寻求优化发现过程.

总结

以上是内存溢出为你收集整理的java – 我有两个Android应用程序,一个可以通过LAN发送特定的IP和其他应用程序接收,但我想通过局域网广播字符串?全部内容,希望文章能够帮你解决java – 我有两个Android应用程序,一个可以通过LAN发送特定的IP和其他应用程序接收,但我想通过局域网广播字符串?所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/web/1110299.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-05-29
下一篇 2022-05-29

发表评论

登录后才能评论

评论列表(0条)

保存