Не отправляется сообщение с сервера к клиенту в Websocket Java

230
02 апреля 2018, 23:31

Прошу не пинать я новичок в Java. Не могу отправить данные с сервера к клиенту. С клиента приходит сообщение но обратно не отправляется. Данные в JSON формате.

Вот исходник:

    public class ImageDecoder {
            String sourceImage;
            String targetImage;
        public String Encode(Reader encode) throws FileNotFoundException, IOException
        {

            JsonParser parser = Json.createParser(encode);
            while(parser.hasNext())
            {
                JsonParser.Event event = parser.next();
                while(parser.hasNext() && !(event.equals(JsonParser.Event.KEY_NAME) && parser.getString().matches("source")))
                {
                  event = parser.next();
                }
                if(event.equals(JsonParser.Event.KEY_NAME) && parser.getString().matches("source"))
                {
                    parser.next();
                    sourceImage = parser.getString();
                }
                while(parser.hasNext() && !(event.equals(JsonParser.Event.KEY_NAME) && parser.getString().matches("target")))
                {
                    event = parser.next();
                }
                if(event.equals(JsonParser.Event.KEY_NAME) && parser.getString().matches("target"))
                {
                    parser.next();
                    targetImage = parser.getString();
                }
            }
            byte[] source = Base64.getDecoder().decode(sourceImage);
            byte[] target = Base64.getDecoder().decode(targetImage);
            ByteBuffer _source = ByteBuffer.wrap(source);
            ByteBuffer _target = ByteBuffer.wrap(target);
            Recognition recognition = new Recognition();
            recognition.FaceRecognition(_source, _target);
            return null;        
        }

public class MassageSendHandler {
    Websocket websocket = new Websocket();
    public MassageSendHandler()
    {}
    public void MessageSend(String confidence, int uncompared) throws IOException, EncodeException
    {
        StringWriter writer = new StringWriter();
        JsonGenerator generator = Json.createGenerator(writer);
        generator.writeStartObject()
                .write("Confidence:", confidence)
                .write("Uncompared:", uncompared)
            .writeEnd()
            .close();

        websocket.OutputJsonMessage(writer);

    }
}
@ServerEndpoint("/wb")
public class Websocket {
private static Set<Session> peers = Collections.synchronizedSet(new HashSet<Session>());
Session _session;
String outputmsg;

@OnOpen
public void OnOpen(Session session)
{
    peers.add(session);
    _session = session;
}

@OnMessage
public void Message(Reader message) throws FileNotFoundException, IOException, EncodeException
{
    ImageDecoder imgdecoder = new ImageDecoder();
    imgdecoder.Encode(message);
}
public void OutputJsonMessage(StringWriter message) throws IOException, EncodeException
{
    outputmsg = message.toString();
    _session.getBasicRemote().sendText("Hellow");
}
@OnClose
public void OnClouse(Session session)
{
   peers.remove(session);
}
READ ALSO
Слушатель на BooleanProperty

Слушатель на BooleanProperty

Добрый день

314
Помощь в переводе кода на java AWT в JavaFX

Помощь в переводе кода на java AWT в JavaFX

Есть код на java awtИз него мне нужна была только "логика"

288
Сглаживание шрифтов в CSS, как? [требует правки]

Сглаживание шрифтов в CSS, как? [требует правки]

Сглаживание шрифтов в CSS, как?

258
Как подключить Bootstrap через @import в СSS

Как подключить Bootstrap через @import в СSS

Люди добрые!) Помогите пожалуйста подключить Bootstrap через @import в СSSСамое интересное Slick-carousel работает а bootstrap нет(( пример на скрине

275