会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132431个问题

Exception:

E:\Java\jdk-11.0.13\bin\java.exe "-javaagent:E:\Program Files\JetBrains\IntelliJ IDEA 2021.2.3\lib\idea_rt.jar=60329:E:\Program Files\JetBrains\IntelliJ IDEA 2021.2.3\bin" -Dfile.encoding=UTF-8 -classpath E:\IdeaProjects\zookeeperclient\target\classes;C:\Users\m1355\.m2\repository\org\apache\zookeeper\zookeeper\3.6.0\zookeeper-3.6.0.jar;C:\Users\m1355\.m2\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;C:\Users\m1355\.m2\repository\org\apache\zookeeper\zookeeper-jute\3.6.0\zookeeper-jute-3.6.0.jar;C:\Users\m1355\.m2\repository\org\apache\yetus\audience-annotations\0.5.0\audience-annotations-0.5.0.jar;C:\Users\m1355\.m2\repository\io\netty\netty-handler\4.1.45.Final\netty-handler-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\io\netty\netty-common\4.1.45.Final\netty-common-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\io\netty\netty-buffer\4.1.45.Final\netty-buffer-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\io\netty\netty-transport\4.1.45.Final\netty-transport-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\io\netty\netty-resolver\4.1.45.Final\netty-resolver-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\io\netty\netty-codec\4.1.45.Final\netty-codec-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\io\netty\netty-transport-native-epoll\4.1.45.Final\netty-transport-native-epoll-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\io\netty\netty-transport-native-unix-common\4.1.45.Final\netty-transport-native-unix-common-4.1.45.Final.jar;C:\Users\m1355\.m2\repository\org\slf4j\slf4j-api\1.7.25\slf4j-api-1.7.25.jar;C:\Users\m1355\.m2\repository\org\slf4j\slf4j-log4j12\1.7.25\slf4j-log4j12-1.7.25.jar;C:\Users\m1355\.m2\repository\log4j\log4j\1.2.17\log4j-1.2.17.jar ClientDemo
log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
连接成功
Exception in thread "main" java.lang.reflect.UndeclaredThrowableException
    at com.sun.proxy.$Proxy3.findUsers(Unknown Source)
    at ClientDemo.main(ClientDemo.java:23)
Caused by: java.rmi.UnexpectedException: unexpected exception; nested exception is: 
    java.rmi.RemoteException: Method is not Remote: interface service.UserService::public abstract java.lang.String service.UserService.findUsers(java.lang.String)
    at java.rmi/java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(RemoteObjectInvocationHandler.java:235)
    at java.rmi/java.rmi.server.RemoteObjectInvocationHandler.invoke(RemoteObjectInvocationHandler.java:162)
    ... 2 more
Caused by: java.rmi.RemoteException: Method is not Remote: interface service.UserService::public abstract java.lang.String service.UserService.findUsers(java.lang.String)
    at java.rmi/java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(RemoteObjectInvocationHandler.java:214)
    ... 3 more

Process finished with exit code 1

Zookeeperserver ——UserSevice Interface/impl

package service;

import java.rmi.Remote;
import java.rmi.RemoteException;

public interface UserService extends Remote {
    String findUsers(String str) throws RemoteException;
}
package service.impl;

import service.UserService;

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

public class UserServiceImpl extends UnicastRemoteObject implements UserService {

    public UserServiceImpl() throws RemoteException {
    }

    @Override
    public String findUsers(String str) throws RemoteException {
        return "Hello ZookeeperRMI "+str;
    }
}

ServerDemo

import org.apache.zookeeper.*;
import service.UserService;
import service.impl.UserServiceImpl;

import java.io.IOException;
import java.rmi.AlreadyBoundException;
import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;

public class ServerDemo implements Watcher {
    public static void main(String[] args) throws IOException, AlreadyBoundException, InterruptedException, KeeperException {

        //实例化需要远程调用的对象
        UserService userService = new UserServiceImpl();

        //(2)定义一个RMI的url地址
        String url = "rmi://localhost:8888/user";

        //(3)创建注册监听端口
        LocateRegistry.createRegistry(8888);

        //(4)绑定对象到注册表
        Naming.bind(url,userService);

        //将url 信息放到zookeeper 的节点中
        ZooKeeper zooKeeper = new ZooKeeper("192.168.192.128:2181,192.168.192.128:2182,192.168.192.128:2183",150000,new ServerDemo());

        //创建Znode节点
        zooKeeper.create("/service",url.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);

        System.out.println("服务发布成功");
    }

    @Override
    public void process(WatchedEvent event) {

    }
}

下面是客户端 ZookeeperClient

UserSevice Interface

package service;

public interface UserService {
    String findUsers(String str);
}

ClientDemo

import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import service.UserService;

import java.io.IOException;
import java.rmi.Naming;
import java.rmi.NotBoundException;

public class ClientDemo implements Watcher {
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException, NotBoundException {
        //(1)创建Zookeeper对象
        ZooKeeper zooKeeper = new ZooKeeper("192.168.192.128:2181,192.168.192.128:2182,192.168.192.128:2183",200000,new ClientDemo());
        //(2)获取指定节点下的数据
        byte[] bytes = zooKeeper.getData("/service0000000002",new ClientDemo(),null);
        String url  = new String(bytes);

        //(3)使用Naming中的方法获得User
        UserService userService = (UserService) Naming.lookup(url);

        //(4)调用UserService中的方法
        String result = userService.findUsers("y");
        System.out.println(result);
    }

    @Override
    public void process(WatchedEvent event) {
        if(event.getState() == Event.KeeperState.SyncConnected){
            System.out.println("连接成功");
        }
    }
}

节点信息

图片.png

老师,我这个就是找不到节点,不懂为什么,求老师帮忙看看

JAVA 全系列/第十一阶段:分布式RPC调用和分布式文件存储/Zookeeper 8524楼
Python 全系列/第一阶段:Python入门/函数和内存分析 8525楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 8526楼
JAVA 全系列/(旧的隐藏)第十一阶段:spring全家桶(Spring Boot)/Spring Boot 8527楼
WEB前端全系列/第六阶段:音乐社区高级项目模块/音乐社区项目_蓝莓派 8528楼
Python 全系列/第十五阶段:Python 爬虫开发/爬虫基础(旧) 8529楼
Python 全系列/第十五阶段:Python 爬虫开发/爬虫基础(旧) 8530楼
Python 全系列/第二阶段:Python 深入与提高/坦克大战 8531楼

# 设置到seaborn

sns.barplot(x=[1,2,3,4,5],y=[1,4,9,16,25],palette=sns.color_palette('husl',5),hue=[1,2,3,4,5],legend=False)


还有警告,显示如下:

e:\Programs\miniconda3\envs\seaborn_env\lib\site-packages\seaborn\_base.py:949: FutureWarning: When grouping with a length-1 list-like, you will need to pass a length-1 tuple to get_group in a future version of pandas. Pass `(name,)` instead of `name` to silence this warning.  data_subset = grouped_data.get_group(pd_key)e:\Programs\miniconda3\envs\seaborn_env\lib\site-packages\seaborn\_base.py:949: FutureWarning: When grouping with a length-1 list-like, you will need to pass a length-1 tuple to get_group in a future version of pandas. Pass `(name,)` instead of `name` to silence this warning.  data_subset = grouped_data.get_group(pd_key)e:\Programs\miniconda3\envs\seaborn_env\lib\site-packages\seaborn\_base.py:949: FutureWarning: When grouping with a length-1 list-like, you will need to pass a length-1 tuple to get_group in a future version of pandas. Pass `(name,)` instead of `name` to silence this warning.  data_subset = grouped_data.get_group(pd_key)e:\Programs\miniconda3\envs\seaborn_env\lib\site-packages\seaborn\_base.py:949: FutureWarning: When grouping with a length-1 list-like, you will need to pass a length-1 tuple to get_group in a future version of pandas. Pass `(name,)` instead of `name` to silence this warning.  data_subset = grouped_data.get_group(pd_key)e:\Programs\miniconda3\envs\seaborn_env\lib\site-packages\seaborn\_base.py:949: FutureWarning: When grouping with a length-1 list-like, you will need to pass a length-1 tuple to get_group in a future version of pandas. Pass `(name,)` instead of `name` to silence this warning.  data_subset = grouped_data.get_group(pd_key)

Python 全系列/第十八阶段:数据分析-数据可视化/seaborn 8533楼
Python 全系列/第十五阶段:Python 爬虫开发/移动端爬虫 8534楼
JAVA 全系列/第一阶段:JAVA 快速入门/变量、数据类型、运算符 8535楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637