Service

package com.gakki;

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

import java.io.IOException;

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


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

  public static void main(String[] args) throws IOException, AlreadyBoundException, KeeperException, InterruptedException {
    //(1)实例化需要远程调用的对象
    UserService userService = new UserServiceImpl();
    //(2)定义一个RMI的url地址
    String url = "rmi://localhost:8888/user";
    //(3)创建注册监听端口
    LocateRegistry.createRegistry(8888);
    //(4)绑定对象到注册表
    Naming.bind(url, userService);
    //(5)将url放到Zookeeper中
      //(1)创建Zookeeper对象
      ZooKeeper zooKeeper = new ZooKeeper("192.168.0.101:2181,192.168.0.101:2182,192.168.0.101:2183",
              150000, new ServiceDemo());
      //(2)创建Znode节点
      zooKeeper.create("/gakki/service", url.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
      System.out.println("服务发布成功");
  }
}

UserService

package com.gakki.service;

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

/**
 * 允许外部远程调用的User服务接口
 * 需要继承Remote接口
 * 允许外部远程调用的方法需要抛出RemoteException异常
 */
public interface UserService extends Remote {
  String findUsers(String str) throws RemoteException;

}

Impl

package com.gakki.service.impl;

import com.gakki.service.UserService;

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

/**
 * UserService实现类
 * 需要继承UnicastRemoteObject类
 * 创建无参构造并改为public.
 */
public class UserServiceImpl extends UnicastRemoteObject implements UserService {

  public UserServiceImpl() throws RemoteException {
  }

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

Client

package com.gakki;

import com.gakki.serivce.UserService;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import java.io.IOException;
import java.rmi.Naming;
import java.rmi.NotBoundException;


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

  public static void main(String[] args) throws IOException, KeeperException, InterruptedException, NotBoundException {
    //(1)创建Zookeeper对象
    ZooKeeper zooKeeper = new ZooKeeper("192.168.0.101:2181,192.168.0.101:2182,192.168.0.101:2183",
            150000, new ClientDemo());
    //(2)获取指定节点下的数据
    byte[] data = zooKeeper.getData("/gakki/service", new ClientDemo(), null);
    String dataString = new String(data);
    //(3)使用Naming中的方法获得User
    UserService userService = (UserService) Naming.lookup(dataString);
    //(4)调用UserService中的方法
    String result = userService.findUsers("nice");
    System.out.println(result);
  }
}

Zookeeper

问题

为什么会报错呢 ？Service 创建成功了。Client 也读取了节点呀 应该代码没问题吧？请老师指点下

安装的都是64位的但是打不开 怎么解决                     

老师，在自己做的HTML中输入java之后出现的URL地址是

老师您好，为什么在django的shell界面中测试时，执行serializer.save()之前需要先执行serializer.validated_data,否则会报错，但是在views.py中，在serializer.save()之前未加上serializer.validated_data，却不会报错？

项目根目录下输入python manage.py shell后，执行如下代码：

# 将 json格式的字节串 转换为字典
from rest_framework.parsers import JSONParser
stream = io.BytesIO(b'{"name":"rose", "age":19, "sex":2}') #这里如果把单引号和双引号交换，执行JSONParser().parse(stream)时会报错rest_framework.exceptions.ParseError: JSON parse error - Expecting property name enclosed in double quotes
# 得到字典数据， {'id': 1,......}
data_dict = JSONParser().parse(stream)

# 将字典数据 反序列化
serializer = StudentSerializer(data=data_dict)
# 必须执行这一步验证， 返回True才可以获取后续的 validated_data数据和执行 save等方法
serializer.is_valid()
# 得到 OrderedDict([('name', 'terry'),......] , 会忽略掉 id 属性
serializer.validated_data
# 保存到数据库中
serializer.save()

django项目的views.py中：

@csrf_exempt
def students(request):
    if request.method == 'GET':
        student_li = Student.objects.all()
        serializer = StudentSerializer(student_li, many=True)
        return JsonResponse(serializer.data, safe=False)

    elif request.method == 'POST':
        data = JSONParser().parse(request)
        serializer = StudentSerializer(data=data)
        if serializer.is_valid():
            serializer.save()
            return JsonResponse(serializer.data, status=201)
        return JsonResponse(serializer.errors, status=400)

c={:::}
(c)

 File "D:\mypro01\my05.py", line 24

    c={'支出金额':300.15,'指出日期':2018.10,18.'指出人':'高校其'}

                                                      ^

SyntaxError: ':' expected after dictionary key

老师这个哪里错了呀

老师，我照着步骤来不对

为什么第26行，手动刷新的flush方法是bos的

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>构造函数</title>
</head>
<body>
<script>
    function Person(name,age,height,a) {
     this.userName=name;
     this.userAge=age;
     this.userHeight=height;
     this.userAbilitty=a;
    }
    var beixi=newPerson=("贾先生","18","60",function () {console.log("敲代码");})
    var shishi=newPerson=("刘诗诗","16","40",function () {console.log("2");})
    console.log(beixi);
    console.log(shishi);
</script>
</body>
</html>

老师我这个怎么是这样的  怎么只出来最后一项内容呢？

1）我在包的__init__.py中定义__all__=['']时，为什么不会自动带出下面的模块，

2）我在from package import *后，使用下面的模块和模块下的函数不会自动带出，

但是视频里，老师敲得代码，会自动带出其下的内容，为什么呢，要怎么操作才会自动带出呢？？？

只有MacOS环境可以怎么验证呢

分享一个帖子：

Class.forName("com.mysql.jdbc.Driver") 什么作用、SPI

https://www.cnblogs.com/qingchen521/p/10331768.html

private void capacity(){
    //数组初始化
    if (this.arr==null){
        this.arr=new Object[this.stackLength];
    }
    //1。5倍扩容
    if (this.size-this.stackLength==0){
        this.stackLength = this.stackLength+(this.stackLength>>1);
        this.arr = Arrays.copyOf(this.arr,this.stackLength);
    }
}

老师，我扩容这么写可以吗

老师那个相关软件和源码在哪里可以找到呢