数据网站排名,怎样了解网站建设是否专业,哪些网站做任务可以赚钱的,seo案例分析及解析websockets因此#xff0c;我一直在研究Tyrus #xff08;JSR 356 WebSocket for Java规范的参考实现#xff09;。 因为我一直在寻找测试工具#xff0c;所以我对在Java中同时运行客户端和服务器端感兴趣。 因此#xff0c;恐怕此博客文章中没有HTML5。 在此示例中… websockets 因此我一直在研究Tyrus JSR 356 WebSocket for Java规范的参考实现。 因为我一直在寻找测试工具所以我对在Java中同时运行客户端和服务器端感兴趣。 因此恐怕此博客文章中没有HTML5。 在此示例中我们想来回发送JSON并且因为我过时了所以我希望能够绑定到POJO对象。 我将为此使用Jackson因此我的Maven文件如下所示 dependenciesdependencygroupIdjavax.websocket/groupIdartifactIdjavax.websocket-api/artifactIdversion1.0-rc3/version/dependencydependencygroupIdorg.glassfish.tyrus/groupIdartifactIdtyrus-client/artifactIdversion1.0-rc3/version/dependencydependencygroupIdorg.glassfish.tyrus/groupIdartifactIdtyrus-server/artifactIdversion1.0-rc3/version/dependencydependencygroupIdorg.glassfish.tyrus/groupIdartifactIdtyrus-container-grizzly/artifactIdversion1.0-rc3/version/dependencydependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-databind/artifactIdversion2.2.0/version/dependencydependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-annotations/artifactIdversion2.2.0/version/dependencydependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-core/artifactIdversion2.2.0/version/dependency/dependencies 因此我们需要做的第一件事就是定义Encode / Decoder接口的实现来为我们完成这项工作。 这将做一些简单的反映来锻炼bean类是什么。 像使用JAX-WS一样将它们放在同一个类中也更容易。 请注意我们使用接口的流版本并且仅处理文本内容。 暂时忽略发送二进制数据的能力 package websocket;import com.fasterxml.jackson.databind.ObjectMapper;import java.io.IOException;
import java.io.Reader;
import java.io.Writer;import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;import javax.websocket.DecodeException;
import javax.websocket.Decoder;
import javax.websocket.EncodeException;
import javax.websocket.Encoder;
import javax.websocket.EndpointConfig;public abstract class JSONCoderTimplements Encoder.TextStreamT, Decoder.TextStreamT{private ClassT _type;// When configured my read in that ObjectMapper is not thread safe//private ThreadLocalObjectMapper _mapper new ThreadLocalObjectMapper() {Overrideprotected ObjectMapper initialValue() {return new ObjectMapper();}};Overridepublic void init(EndpointConfig endpointConfig) {ParameterizedType $thisClass (ParameterizedType) this.getClass().getGenericSuperclass();Type $T $thisClass.getActualTypeArguments()[0];if ($T instanceof Class) {_type (ClassT)$T;}else if ($T instanceof ParameterizedType) {_type (ClassT)((ParameterizedType)$T).getRawType();}}Overridepublic void encode(T object, Writer writer) throws EncodeException, IOException {_mapper.get().writeValue(writer, object);}Overridepublic T decode(Reader reader) throws DecodeException, IOException {return _mapper.get().readValue(reader, _type);}Overridepublic void destroy() {}} Bean类实际上非常简单带有Coder的静态子类以后我们可以使用它。 package websocket;public class EchoBean {public static class EchoBeanCode extendsJSONCoderEchoBean {}private String _message;private String _reply;public EchoBean() {}public EchoBean(String _message) {super();this._message _message;}public void setMessage(String _message) {this._message _message;}public String getMessage() {return _message;}public void setReply(String _reply) {this._reply _reply;}public String getReply() {return _reply;}} 因此我们需要实现服务器端点因此可以采用两种方式之一即注释POJO或扩展端点。 我要为服务器使用第一个为客户端使用第二个。 实际上此服务所做的全部工作就是将消息发布回客户端。 请注意编码和解码器的注册。 在这种情况下是相同的类。 package websocket;import java.io.IOException;import javax.websocket.EncodeException;
import javax.websocket.EndpointConfig;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import static java.lang.System.out;ServerEndpoint(value/echo,encoders {EchoBean.EchoBeanCode.class},decoders {EchoBean.EchoBeanCode.class})
public class EchoBeanService
{OnMessagepublic void echo (EchoBean bean, Session peer) throws IOException, EncodeException {//bean.setReply(Server says bean.getMessage());out.println(Sending message to client);peer.getBasicRemote().sendObject(bean);}OnOpenpublic void onOpen(final Session session, EndpointConfig endpointConfig) {out.println(Server connected session endpointConfig);}
} 让我们看一下客户端bean这次扩展了标准Endpoint类并为消息添加了特定的侦听器。 在这种情况下当收到消息时只需关闭连接即可简化我们的测试案例。 在现实世界中管理这种连接显然会更加复杂。 package websocket;import java.io.IOException;import javax.websocket.ClientEndpoint;
import javax.websocket.CloseReason;
import javax.websocket.EncodeException;
import javax.websocket.Endpoint;
import javax.websocket.EndpointConfig;
import javax.websocket.MessageHandler;
import javax.websocket.Session;import static java.lang.System.out;ClientEndpoint(encoders {EchoBean.EchoBeanCode.class},decoders {EchoBean.EchoBeanCode.class})
public class EchoBeanClient extends Endpoint
{public void onOpen(final Session session, EndpointConfig endpointConfig) {out.println(Client Connection open session endpointConfig);// Add a listener to capture the returning event//session.addMessageHandler(new MessageHandler.Whole() {Overridepublic void onMessage(EchoBean bean) {out.println(Message from server : bean.getReply());out.println(Closing connection);try {session.close(new CloseReason(CloseReason.CloseCodes.NORMAL_CLOSURE, All fine));} catch (IOException e) {e.printStackTrace();}}});// Once we are connected we can now safely send out initial message to the server//out.println(Sending message to server);try {EchoBean bean new EchoBean(Hello);session.getBasicRemote().sendObject(bean);} catch (IOException e) {e.printStackTrace();} catch (EncodeException e) {e.printStackTrace();}}
} 现在使用Tyrus运行WebSocket独立非常简单您只需实例化服务器并启动它。 请注意这会启动守护程序线程因此您需要确保它是否在main方法中并且您需要执行一些操作来保持JVM的生命。 import org.glassfish.tyrus.server.Server;Server server new Server(localhost, 8025, /, EchoBeanService.class);
server.start(); 因此客户相对简单 但是在执行声明式方法时我们需要在注册客户端类时显式注册编码器和解码器。 import javax.websocket.ClientEndpointConfig;
import javax.websocket.Decoder;
import javax.websocket.Encoder;
import javax.websocket.Session;import org.glassfish.tyrus.client.ClientManager;// Right now we have to create a client, which will send a message then close
// when it has received a reply
//ClientManager client ClientManager.createClient();
EchoBeanClient beanClient new EchoBeanClient();Session session client.connectToServer(beanClient, ClientEndpointConfig.Builder.create().encoders(Arrays.Class? extends EncoderasList(EchoBean.EchoBeanCode.class)).decoders(Arrays.Class? extends DecoderasList(EchoBean.EchoBeanCode.class)).build(),URI.create(ws://localhost:8025/echo));// Wait until things are closed downwhile (session.isOpen()) {out.println(Waiting);TimeUnit.MILLISECONDS.sleep(10);
} 现在其输出如下所示 Server connected SessionImpl{uri/echo, ide7739cc8-1ce5-4c26-ad5f-88a24c688799, endpointEndpointWrapper{endpointClassnull, endpointorg.glassfish.tyrus.core.AnnotatedEndpoint1ce5bc9, uri/echo, contextPath/}} javax.websocket.server.DefaultServerEndpointConfigec120d
Waiting
Client Connection open SessionImpl{uriws://localhost:8025/echo, id7428be2b-6f8a-4c40-a0c4-b1c8b22e1338, endpointEndpointWrapper{endpointClassnull, endpointwebsocket.EchoBeanClient404c85, uriws://localhost:8025/echo, contextPathws://localhost:8025/echo}} javax.websocket.DefaultClientEndpointConfig15fdf14
Sending message to server
Waiting
Waiting
Waiting
Waiting
Waiting
Waiting
Waiting
Waiting
Waiting
Waiting
Sending message to client
Message from server : Server says Hello
Closing connection
Waiting 有趣的是这是第一次运行会有一个暂停我怀疑这是由于杰克逊Jackson自己设置的但我没有时间进行分析。 我确实发现这种漫长的延迟发生在第一篇文章上-尽管显然这比一般地传递纯文本消息要慢。 差异是否对您很重要取决于您的应用程序。 将纯文本的性能与JSON流API例如由新JSR提供的JSON流API以及将这些值绑定到JSON POJO的版本进行比较将会很有趣。 也许是另一天的事情。 参考 Gerard Davison博客博客中的JCG合作伙伴 Gerard Davison 使用Java WebSocketsJSR 356和JSON映射到POJO 。 翻译自: https://www.javacodegeeks.com/2013/05/using-java-websockets-jsr-356-and-json-mapped-to-pojos.htmlwebsockets
