用于初始化与其他Websocket服务器的连接的websocket服务器

Question

有没有办法让websocket服务器连接到另一个websocket服务器？我用Java写了这段代码，但它不能工作。我没有得到任何错误或异常，它只是永远等待连接。

@OnMessage
    public void message(Session session, String msg){
        String URL = "ws://wildfly2-ciri.rhcloud.com:8000/echo";
        try {
            System.out.println("**1 Got new message: " + msg);
            String forward = "This is WildFly 1: " + msg;
            System.out.println("**1 Init new session");
            Session newSession =  session.getContainer().connectToServer(Client.class, URI.create(URL));
            System.out.println("**1 Sending to wildfly2");
            newSession.getBasicRemote().sendText(forward);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

基本上，我希望这个服务器初始化一个新的websocket连接到另一个地址的另一个服务器。但是，程序会在尝试建立新连接时停止。是我的思维有缺陷，还是这种联系是不可能的？

Answer 1

您可能会发现这很有用。这是我的一个旧的套接字程序，我用它来在客户端和服务器之间通信。我已附上客户端和代码的程序，这将发送XML文件。但是，您需要编辑一些内容，以便让她为您工作。播放这个文件，并获得套接字的感觉，并将其应用到您的程序中。朋友，祝你学习快乐！

public static void main(String[] args) throws IOException {
    Socket socket = null;
    String host = "127.0.0.1";

    socket = new Socket(host, 4444);

    File file = new File("C:\\testXML.xml");
    // Get the size of the file
    long length = file.length();
    if (length > Integer.MAX_VALUE) {
        System.out.println("File is too large.");
    }
    byte[] bytes = new byte[(int) length];
    FileInputStream fis = new FileInputStream(file);
    BufferedInputStream bis = new BufferedInputStream(fis);
    BufferedOutputStream out = new BufferedOutputStream(socket.getOutputStream());

    int count;

    while ((count = bis.read(bytes)) > 0) {
        out.write(bytes, 0, count);
    }

    out.flush();
    out.close();
    fis.close();
    bis.close();
    socket.close();
    }
}

public class Server {

/**
 * @param args the command line arguments
 */
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = null;

        try {
            serverSocket = new ServerSocket(4444);
        } catch (IOException ex) {
            System.out.println("Can't setup server on this port number. ");
        }

        Socket socket = null;
        InputStream is = null;
        FileOutputStream fos = null;
        BufferedOutputStream bos = null;
        int bufferSize = 0;

        try {
            socket = serverSocket.accept();
        } catch (IOException ex) {
            System.out.println("Can't accept client connection. ");
        }

        try {
            is = socket.getInputStream();

            bufferSize = socket.getReceiveBufferSize();
            System.out.println("Buffer size: " + bufferSize);
        } catch (IOException ex) {
            System.out.println("Can't get socket input stream. ");
        }

        try {
            fos = new FileOutputStream("C:\\xxxXXXXxxx.txt");
            bos = new BufferedOutputStream(fos);

        } catch (FileNotFoundException ex) {
            System.out.println("File not found. ");
        }

        byte[] bytes = new byte[bufferSize];

        int count;

        while ((count = is.read(bytes)) > 0) {
            bos.write(bytes, 0, count);
        }

        bos.flush();
        bos.close();
        is.close();
        socket.close();
        serverSocket.close();
        }
    }