Shulou(Shulou.com)05/31 Report--

This article introduces the relevant knowledge of "how to implement the SocketD protocol message reporting mode". Many people will encounter such a dilemma in the operation of actual cases, so let the editor lead you to learn how to deal with these situations. I hope you can read it carefully and be able to achieve something!

SocketD is a binary point-to-point communication protocol and a new network communication layer 7 protocol. Designed to be used in distributed applications. In this sense, SocketD can be an alternative to other similar protocols such as RSocket. Its message protocol specification has the characteristics of asynchronism, two-way back pressure, multiplexing, disconnection reconnection, message-based and so on. Only Java implementation is provided for the time being, and it is currently used as the sockte channel protocol for Solon rpc.

Server / / start server public class ServerApp {public static void main (String [] args) {/ / launch Solon container (SocketD bean&plugin is managed by solon container) Solon.start (ServerApp.class, args, app-> app.enableSocketD (true)) }} / / define server snooping @ ServerEndpointpublic class ServerListener implements Listener {@ Override public void onOpen (Session session) {System.out.println ("there is a client link...") } @ Override public void onMessage (Session session, Message message) {/ / receive the message and do business processing if (message.flag () = = MessageFlag.heartbeat) {System.out.println ("server: I received a heartbeat");} else {System.out.println ("server: I received:" + message.bodyAsString ()) } client / / launch client public class ClientApp {public static void main (String [] args) throws Throwable {/ / launch Solon container (SocketD bean&plugin is managed by solon container) Solon.start (ClientApp.class, args); / / create a session (if the backend is WebSocekt, the protocol header is: ws) Session session = SocketD.createSession ("tcp://localhost:28080") / / set 30 seconds to automatically send the heartbeat (if disconnected, also try automatic heavy link) session.sendHeartbeatAuto (30); / / report the message session.send ("Helloworld server!");}} "how to implement the SocketD protocol message reporting mode". Thank you for reading. If you want to know more about the industry, you can follow the website, the editor will output more high-quality practical articles for you!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.