java websocket 客户端

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>JavaNative</groupId>
    <artifactId>JavaNative</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>JavaNative</name>
    <url>http://maven.apache.org</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.glassfish.tyrus.bundles</groupId>
            <artifactId>tyrus-standalone-client</artifactId>
            <version>1.9</version>
        </dependency>
    </dependencies>
</project>

websocket.client.SimpleClient

package websocket.client;

import javax.websocket.*;
import java.io.IOException;
import java.net.URI;

/**
 * Created by Administrator on 2016/4/17.
 */
@ClientEndpoint
public class SimpleClient {
    @OnOpen
    public void onOpen(Session session) {
        System.out.println("open ... ");
    }

    @OnMessage
    public void onMessage(String message) {
        System.out.println(message);
    }

    @OnError
    public void onError(Throwable t) {
        t.printStackTrace();
    }

    public static void main(String[] args)throws Exception{
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        String uri ="ws://localhost:8077/web/SimpleWebSocket";
        System.out.println("Connecting to 2"+ uri);
        Session session = container.connectToServer(SimpleClient.class, URI.create(uri));
        session.getBasicRemote().sendText("这是从java客户端发送的消息 。。。");
        Thread.sleep(1000);
        session.close();
    }
}
时间: 2024-08-01 22:46:54

java websocket 客户端的相关文章

使用Jetty搭建Java Websocket Server,实现图像传输

https://my.oschina.net/yushulx/blog/298140 How to Implement a Java WebSocket Server for Image Transmission with Jetty 创建一个从WebSocketHandler继承的类WSHandler: import org.eclipse.jetty.websocket.api.Session; import org.eclipse.jetty.websocket.api.annotatio

Java WebSocket生命周期

本章将讲述WebSocket端点的生命周期.WebSocket端点的生命周期为开发人员提供了一个框架来管理端点所需要的资源,也提供了一个框架来拦截消息.我们将仔细探讨其生命周期的顺序和语义,以及Java WebSocket API如何提供API和注解来支持处理这些事件. 一.WebSocket协议 与基于HTTP的技术不同,WebSocket具有生命周期.此生命周期周期由WebSocket协议支撑.WebSocket协议定义了客户端和服务器长时间存活的专用的TCP连接,一旦连接已经建立,数据的传

java WebSocket的实现以及Spring WebSocket

开始学习WebSocket,准备用它来实现一个在页面实时输出log4j的日志以及控制台的日志. 首先知道一些基础信息: java7 开始支持WebSocket,并且只是做了定义,并未实现 tomcat7及以上,jetty 9.1及以上实现了WebSocket,其他容器没有研究 spring 4.0及以上增加了WebSocket的支持 spring 支持STOMP协议的WebSocket通信 WebSocket 作为java的一个扩展,它属于javax包目录下,通常需要手工引入该jar,以tomc

java实现客户端向服务器发送文件的操作

服务器源代码: import java.io.BufferedReader; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.ServerSocket;

[JAVA] Tcp客户端和服务器简单代码

服务器: 1 import java.io.DataInputStream; 2 import java.io.DataOutputStream; 3 import java.io.IOException; 4 import java.net.ServerSocket; 5 import java.net.Socket; 6 7 public class TcpServer { 8 public static void main(String [] args) throws IOExceptio

一种类型安全的Java HTTP客户端库Retrofit

一种类型安全的Java HTTP客户端库Retrofit 作者:chszs,未经博主允许不得转载.经许可的转载需注明作者和博客主页:http://blog.csdn.net/chszs 一.Retrofit介绍 Retrofit是一个开源的.类型安全的HTTP客户端,它适用于Android和Java平台,官方主页为: http://square.github.io/retrofit/ Retrofit需要Java 7以上版本或Android 2.3以上版本的支持. 二.Retrofit依赖 Re

java获取客户端IP地址和MAC地址

最近项目中要获得客户端的mac地址.服务端是移植的centos系统,arm架构的盒子.客户端是手机和移动设备.(其它场景应该也是类似的) 首先要获得ip地址: 根据客户端的http请求,利用request.getRemoteAddr()获取客户端Ip地址.在局域网内getRemoteAddr()和getRemoteHost()获得的结果相同.request.getRemoteAddr()是获得客户端的ip地址 .getRemoteHost()是获得客户端的主机名 .在有些场景中,可能有Squid

java获取客户端登陆地址信息(国家、省份、城市等)

原文:java获取客户端登陆地址信息(国家.省份.城市等) 源代码下载地址:http://www.zuidaima.com/share/1550463687658496.htm /** * @param urlStr * 请求的地址 * @param content * @author www.zuidaima.com * 请求的参数 格式为:name=xxx&pwd=xxx * @param encoding * 服务器端请求编码.如GBK,UTF-8等 * @return */ privat

Java 多客户端版 2048 源码

byte包 Calss Byte 1 package Byte; 2 import java.io.*; 3 public class Byte implements Serializable{ 4 public static byte[] int2Byte(int []intValue){ 5 int length=intValue.length; 6 byte[] b=new byte[length*4]; 7 for(int i=0;i<length;i++){ 8 for(int j=0