Java教程

阶段4模块2作业

本文主要是介绍阶段4模块2作业，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

注意：安装zookeeper,启动zookeeper服务，我只起了当前这一台虚拟机，所以之前配置的集群起不来，需要修改conf文件夹下的zoo.cfg,将集群节点注释掉，记得用完恢复。

安装之前需要先安装好zookeeper 和 kafka
zookeeper配置文件

image-20220118001753774

Kafka 的server.properties 配置

在这里插入图片描述
在这里插入图片描述

上面两个安装完成，并测试可以启动，开始安装nginx和ngx_kafka_module

确认安装以下jar包
yum -y install gcc pcre-devel zlib-devel openssl openssl-devel
编译librdkafka
#cd librdkafka目录
make & make install

#注意这个需要git,编译之前要先 git init一下
安装nginx
Yum install -y nginx 下载nginx ng版本 1.18.0

也可以下载tar包，解压，重要的是配置文件，配置nginx.conf如下：server_name是后台的服务器地址。
在这里插入图片描述

下载ngx_kafka_module nginx
#在解压的nginx文件夹下执行下面的命令，将nginx和module结合起来。

./configure --add-module=/opt/ngx_kafka_module

make & make install 

#之后启动nginx,首先到下面这个目录，他的可执行程序在下面这个目录
cd /usr/local/nginx/sbin
#初次启动
 ./nginx -c /customSoft/nginx/nginx-1.18.0/conf/nginx.conf 
#后面启动
 
./nginx -c /customSoft/nginx/nginx-1.18.0/conf/nginx.conf -s reload

#启动异常
error while loading shared libraries: librdkafka.so.1: cannot open shared object file: No such file or directory

#解决方案

加载so库
#开机加载/usr/local/lib下面的库
echo "/usr/local/lib" >> /etc/ld.so.conf
 
#手动加载
ldconfig
测试：
[root@localhost customSoft]# curl http://192.168.31.11:80/kafka/log -d "kafka testing"
[root@localhost customSoft]# curl http://192.168.31.11:80/kafka/log -d "i am liuchang , tested kafka is used"

#消费消息
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic user_info_topic --from-beginning
效果

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-AguWbplb-1642518221885)(/Users/liuchang/Library/Application Support/typora-user-images/image-20220118003806669.png)]

编写前台代码：
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>我的大数据作业</title>
    <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.5.1/jquery.js"></script>
</head>
<body>
    <input type="button" onclick="clickInout('click')" value="点击我">
</body>

<script>
    function clickInout (action){
        var user = {
            "user_id":0001,
            "user_name":"liuchang",
            "class":"big data",
            "action":action
        }

        $.ajax({
            url: "http://192.168.31.11:80/kafka/log",
            type: "POST",
            crossDomain: true,
            data: JSON.stringify(user),
            // 下面这句话允许跨域的cookie访问
            xhrFields: {
                withCredentials: true
            },

            success:function (data, status, xhr) {
            // console.log("操作成功：'" + action)
            },
            error:function (err) {
                // console.log(err.responseText);
            }
        });
    };
</script>
</html>
最终结果

在这里插入图片描述

这篇关于阶段4模块2作业的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航