java - 点对点信使

标签 java sockets p2p

我正在尝试使用套接字编写一个桌面聊天应用程序,我的目的是创建一个在客户端之间使用点对点通信的消息传递系统。

如果我有目标收件人的 IP 地址,我可以直接连接到客户端而不必担心中间服务器吗?

如果有人能帮助我指明正确的方向,我将非常感激。

最佳答案

是的,如果您知道收件人的地址是什么,这很容易。只需通过连接以纯文本形式发送消息,用换行符、空终止符分隔,在实际文本之前写入消息长度等。
以下是客户端网络的示例类:

import java.net.Socket;
import java.net.InetAddress;
import java.net.SocketTimeoutException;
import java.io.IOException;
import java.io.OutputStream;
import java.io.InputStream;

public class Networker{
    private Socket conn;

    public void connectTo(InetAddress addr)throws IOException{
        conn = new Socket(addr, 8989); //Second argument is the port you want to use for your chat
        conn.setSoTimeout(5); //How much time receiveMessage() waits for messages before it exits
    }

    public void sendMessage(String message)throws IOException{
        //Here I put one byte indicating the length of the message at the beginning
        //Get the length of the string
        int length = message.length();

        //Because we are using one byte to tell the server our message length,
        //we cap it to 255(max value an UNSIGNED byte can hold)
        if(length > 255)
            length = 255;

        OutputStream os = conn.getOutputStream();
        os.write(length);
        os.write(message.getBytes(), 0, length);
    }

    //Checks if a message is available
    //Should be called periodically
    public String receiveMessage()throws IOException{
        try{
            InputStream is = conn.getInputStream();

            int length = is.read();

            //Allocate a new buffer to store what we received
            byte[] buf = new byte[length];

            //The data received may be smaller than specified
            length = is.read(buf);

            return new String(buf, 0, length);
        }catch(SocketTimeoutException e){} //Nothing special,
        //There was just no data available when we tried to read a message
        return null;
    }
}

尽管如此,我听说某些防火墙会阻止传入连接,在这种情况下您必须使用 UDP。它的问题是它不可靠(也就是说,如果你只是发送消息,它们可能不会到达目的地)

在我看来,P2P 的真正问题是找到对等点(实际上,只有一个是必要的,因为之后我们的新对等点将告诉我们有关其对等点的信息,以及这些对等点有关其对等点的信息,等等)

关于java - 点对点信使,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37682036/

相关文章:

aggregate-functions - 一种点对点和隐私感知的数据挖掘/聚合算法 : is it possible?

javascript - Nativescript - tns 创建测试应用程序错误

java - 使用 Spring 的事务管理器进行回滚

java - BigTable 与 noSQL

c - TCP 上的可变长度消息

c# - 点对点去中心化网络——向所有点发送消息

c++ - 重定向打开的 TCP 连接

java - 重复 Android 抬头通知

python - python 中(多线程)套接字的列表/数组

Java - 通过套接字发送指向 BufferedImage 的对象