Блог

Мне нужно отправить текст, примитивные типы данных и объект между UWP-клиентом и JAVA-сервером с помощью WebSocket, однако я не знаю, как кодировать.

Я не понимаю, есть ли какая-либо разница между этими двумя языками, которые делают кодирование действительно сложным? (Я искал онлайн-руководства, но все еще не мог заставить свой код работать).

Provider.java :

 public class Provider{
    ServerSocket providerSocket;
    Socket connection = null;
    OutputStream out;
    InputStream in;
    String message;
    MesageModel model;
    Provider(){}
    void run()
    {
        try{
            providerSocket = new ServerSocket(9999, 10);
            //2. Wait for connection
            System.out.println("Waiting for connection");
            connection = providerSocket.accept();
            System.out.println("New connection accepted " ":"   connection.getPort());
            in = connection.getInputStream();
            out = connection.getOutputStream();
            if(out == null)
            {
                System.out.println("Out Status : Null");
            }else
            {
                System.out.println("Out Status : Not Null");
                sendMessage("Hello Client");
            }
            if(in == null)
            {
                System.out.println("In Status : Null");
            }else
            {
                receiveConnection();
            }
        }
        catch(IOException ioException){
            ioException.printStackTrace();
        }
        finally{
            //4: Closing connection
            try{
                if(in != null){
                    System.out.println("Close In");
                in.close();
                }
                if(out != null){
                    System.out.println("Close Out");
                     out.close();
                }
                System.out.println("Close Socket");
                 providerSocket.close();
            }
            catch(IOException ioException){
                ioException.printStackTrace();
            }
        }
    }
    void receiveConnection() throws IOException{
        BufferedReader reader = new BufferedReader(new InputStreamReader(in));
        StringBuilder outsb = new StringBuilder();
        String line = "";
        System.out.println("In Status : Not Null");
        System.out.println("In Status : Go To While to Read Line");
        while ((line = reader.readLine()) != null) {
            outsb.append(line);
            System.out.println(outsb.toString()); 
        }
        System.out.println(outsb.toString());   
        reader.close();
        System.out.println("Closed Reader");
    }
    void sendMessage(String msg)
    {
        byte[] byteS = msg.getBytes();
        try{
            out.write(byteS);
            out.flush();
            System.out.println("To Server >"   msg);
        }
        catch(IOException ioException){
            ioException.printStackTrace();
        }
    }
    public static void main(String args[])
    {
        Provider server = new Provider();
        while(true){
            server.run();
        }
    }
}
 

MainPage.xaml.cs

 namespace WebsocketTest
{
    public sealed partial class MainPage : Page
    {
        public MainPage()
        {
            this.InitializeComponent();
            createSocket();
        }
        public async void createSocket()
        {
            MessageWebSocket webSock = new MessageWebSocket();
            webSock.Control.MessageType = SocketMessageType.Binary;
            webSock.MessageReceived  = webSock_MsgReceived;
            webSock.Closed  = webSock_Closed;
            Uri serverUri = new Uri("ws://localhost:9999");
            try
            {
                await webSock.ConnectAsync(serverUri);
                tbConnect.Text = "Connected";
                webSock_SendMessage( webSock, "Hello");
                tbError.Text = "Sent Greeting";
            }
            catch (Exception ex)
            {
                tbError.Text = ex.Message   " / "   ex.HResult   " / "   ex.Data;
            }
        }

        private async Task webSock_SendMessage(MessageWebSocket webSock, string m)
        {
            BinaryWriter messageWriter = new BinaryWriter((Stream)webSock.OutputStream);
            messageWriter.Write(m);
        }

        private void webSock_Closed(IWebSocket sender, WebSocketClosedEventArgs args)
        {

        }

        private void webSock_MsgReceived(MessageWebSocket sender, MessageWebSocketMessageReceivedEventArgs args)
        {   
            DataReader messageReader = args.GetDataReader();
            messageReader.UnicodeEncoding = Windows.Storage.Streams.UnicodeEncoding.Utf8;
            string messageString = messageReader.ReadString(messageReader.UnconsumedBufferLength);
            tbReceived.Text = messageString;
        }
    }
}
 

В настоящее время этот код вообще не работает, … Я не могу отправить, не могу прочитать… с обеих сторон.

Мои вопросы:

Как отправлять и читать сообщения с моего UWP-клиента?

Как отправлять и читать сообщения с моего JAVA-сервера?

Пожалуйста, мне нужно что-то полезное… пример кода.

Ваш Java-код создает обычный сокет TCP / IP, а не [websocket] [1], который является протоколом более высокого уровня поверх TCP / IP.

Если вам нужны websockets, вам нужно либо реализовать websockets для себя (не делайте этого, если вы не очень опытны в сетевом программировании), либо использовать библиотеку Java, которая предоставляет функциональность сервера websocket. Серверы Jetty, Netty или J2EE могут быть кандидатами на это.