导航菜单

  • 0.api
  • 0.Async
  • 0.module
  • 1.ES2015
  • 2.Promise
  • 3.Node
  • 4.NodeInstall
  • 5.REPL
  • 6.NodeCore
  • 7.module&NPM
  • 8.Encoding
  • 9.Buffer
  • 10.fs
  • 11.Stream-1
  • 11.Stream-2
  • 11.Stream-3
  • 11.Stream-4
  • 12-Network-2
  • 12.NetWork-3
  • 12.Network-1
  • 13.tcp
  • 14.http-1
  • 14.http-2
  • 15.compress
  • 16.crypto
  • 17.process
  • 18.yargs
  • 19.cache
  • 20.action
  • 21.https
  • 22.cookie
  • 23.session
  • 24.express-1
  • 24.express-2
  • 24.express-3
  • 24.express-4
  • 25.koa-1
  • 26.webpack-1-basic
  • 26.webpack-2-optimize
  • 26.webpack-3-file
  • 26.webpack-4.tapable
  • 26.webpack-5-AST
  • 26.webpack-6-sources
  • 26.webpack-7-loader
  • 26.webpack-8-plugin
  • 26.webpack-9-hand
  • 26.webpack-10-prepare
  • 28.redux
  • 28.redux-jwt-back
  • 28.redux-jwt-front
  • 29.mongodb-1
  • 29.mongodb-2
  • 29.mongodb-3
  • 29.mongodb-4
  • 29.mongodb-5
  • 29.mongodb-6
  • 30.cms-1-mysql
  • 30.cms-2-mysql
  • 30.cms-3-mysql
  • 30.cms-4-nunjucks
  • 30.cms-5-mock
  • 30.cms-6-egg
  • 30.cms-7-api
  • 30.cms-8-roadhog
  • 30.cms-9-yaml
  • 30.cms-10-umi
  • 30.cms-12-dva
  • 30.cms-13-dva-ant
  • 30.cms-14-front
  • 30.cms-15-deploy
  • 31.dva
  • 31.cms-13-dva-antdesign
  • 33.redis
  • 34.unittest
  • 35.jwt
  • 36.websocket-1
  • 36.websocket-2
  • 38.chat-api-1
  • 38.chat-api-2
  • 38.chat-3
  • 38.chat-api-3
  • 38.chat
  • 38.chat2
  • 38.chat2
  • 39.crawl-0
  • 39.crawl-1
  • 39.crawl-2
  • 40.deploy
  • 41.safe
  • 42.test
  • 43.nginx
  • 44.enzyme
  • 45.docker
  • 46.elastic
  • 47.oauth
  • 48.wxpay
  • index
  • 52.UML
  • 53.design
  • index
  • 54.linux
  • 57.ts
  • 56.react-ssr
  • 58.ts_react
  • 59.ketang
  • 59.ketang2
  • 61.1.devops-linux
  • 61.2.devops-vi
  • 61.3.devops-user
  • 61.4.devops-auth
  • 61.5.devops-shell
  • 61.6.devops-install
  • 61.7.devops-system
  • 61.8.devops-service
  • 61.9.devops-network
  • 61.10.devops-nginx
  • 61.11.devops-docker
  • 61.12.devops-jekins
  • 61.13.devops-groovy
  • 61.14.devops-php
  • 61.15.devops-java
  • 61.16.devops-node
  • 61.17.devops-k8s
  • 62.1.react-basic
  • 62.2.react-state
  • 62.3.react-high
  • 62.4.react-optimize
  • 62.5.react-hooks
  • 62.6.react-immutable
  • 62.7.react-mobx
  • 62.8.react-source
  • 63.1.redux
  • 63.2.redux-middleware
  • 63.3.redux-hooks
  • 63.4.redux-saga
  • 63.5.redux-saga-hand
  • 64.1.router
  • 64.2.router-connected
  • 65.1.typescript
  • 65.2.typescript
  • 65.3.typescript
  • 65.4.antd
  • 65.4.definition
  • 66-1.vue-base
  • 66-2.vue-component
  • 66-3.vue-cli3.0
  • 66-4.$message组件
  • 66-5.Form组件
  • 66-6.tree
  • 66-7.vue-router-apply
  • 66-8.axios-apply
  • 66-9.vuex-apply
  • 66-10.jwt-vue
  • 66-11.vue-ssr
  • 66-12.nuxt-apply
  • 66-13.pwa
  • 66-14.vue单元测试
  • 66-15.权限校验
  • 67-1-network
  • 68-2-wireshark
  • 7.npm2
  • 69-hooks
  • 70-deploy
  • 71-hmr
  • 72.deploy
  • 73.import
  • 74.mobile
  • 75.webpack-1.文件分析
  • 75.webpack-2.loader
  • 75.webpack-3.源码流程
  • 75.webpack-4.tapable
  • 75.webpack-5.prepare
  • 75.webpack-6.resolve
  • 75.webpack-7.loader
  • 75.webpack-8.module
  • 75.webpack-9.chunk
  • 75.webpack-10.asset
  • 75.webpack-11.实现
  • 76.react_optimize
  • 77.ts_ketang_back
  • 77.ts_ketang_front
  • 78.vue-domdiff
  • 79.grammar
  • 80.tree
  • 81.axios
  • 82.1.react
  • 82.2.react-high
  • 82.3.react-router
  • 82.4.redux
  • 82.5.redux_middleware
  • 82.6.connected
  • 82.7.saga
  • 82.8.dva
  • 82.8.dva-source
  • 82.9.roadhog
  • 82.10.umi
  • 82.11.antdesign
  • 82.12.ketang-front
  • 82.12.ketang-back
  • 83.upload
  • 84.graphql
  • 85.antpro
  • 86.1.uml
  • 86.2.design
  • 87.postcss
  • 88.react16-1
  • 89.nextjs
  • 90.react-test
  • 91.react-ts
  • 92.rbac
  • 93.tsnode
  • 94.1.JavaScript
  • 94.2.JavaScript
  • 94.3.MODULE
  • 94.4.EventLoop
  • 94.5.文件上传
  • 94.6.https
  • 94.7. nginx
  • 95.1. react
  • 95.2.react
  • 96.1.react16
  • 96.2.fiber
  • 96.3.fiber
  • 97.serverless
  • 98.websocket
  • 100.1.react-basic
  • 101.1.monitor
  • 101.2.monitor
  • 102.java
  • 103.1.webpack-usage
  • 103.2.webpack-bundle
  • 103.3.webpack-ast
  • 103.4.webpack-flow
  • 103.5.webpack-loader
  • 103.6.webpack-tapable
  • 103.7.webpack-plugin
  • 103.8.webpack-optimize1
  • 103.9.webpack-optimize2
  • 103.10.webpack-hand
  • 103.11.webpack-hmr
  • 103.11.webpack5
  • 103.13.splitChunks
  • 103.14.webpack-sourcemap
  • 103.15.webpack-compiler1
  • 103.15.webpack-compiler2
  • 103.16.rollup.1
  • 103.16.rollup.2
  • 103.16.rollup.3
  • 103.16.vite.basic
  • 103.16.vite.source
  • 103.16.vite.plugin
  • 103.16.vite.1
  • 103.16.vite.2
  • 103.17.polyfill
  • 104.1.binary
  • 104.2.binary
  • 105.skeleton
  • 106.1.react
  • 106.2.react_hooks
  • 106.3.react_router
  • 106.4.redux
  • 106.5.redux_middleware
  • 106.6.connected-react-router
  • 106.6.redux-first-history
  • 106.7.redux-saga
  • 106.8.dva
  • 106.9.umi
  • 106.10.ketang
  • 106.11.antdesign
  • 106.12.antpro
  • 106.13.router-6
  • 106.14.ssr
  • 106.15.nextjs
  • 106.16.1.cms
  • 106.16.2.cms
  • 106.16.3.cms
  • 106.16.4.cms
  • 106.16.mobx
  • 106.17.fomily
  • 107.fiber
  • 108.http
  • 109.1.webpack_usage
  • 109.2.webpack_source
  • 109.3.dll
  • 110.nest.js
  • 111.xstate
  • 112.Form
  • 113.redux-saga
  • 114.react+typescript
  • 115.immer
  • 116.pro5
  • 117.css-loader
  • 118.1.umi-core
  • 119.2.module-federation
  • 119.1.module-federation
  • 120.create-react-app
  • 121.react-scripts
  • 122.react-optimize
  • 123.jsx-runtime
  • 124.next.js
  • 125.1.linux
  • 125.2.linux-vi
  • 125.3.linux-user
  • 125.4.linux-auth
  • 125.5.linux-shell
  • 125.6.linux-install
  • 125.7.linux-system
  • 125.8.linux-service
  • 125.9.linux-network
  • 125.10.nginx
  • 125.11.docker
  • 125.12.ci
  • 125.13.k8s
  • 125.14.k8s
  • 125.15.k8s
  • 125.16.k8s
  • 126.11.react-1
  • 126.12.react-2
  • 126.12.react-3
  • 126.12.react-4
  • 126.12.react-5
  • 126.12.react-6
  • 126.12.react-7
  • 126.12.react-8
  • 127.frontend
  • 128.rollup
  • 129.px2rem-loader
  • 130.health
  • 131.hooks
  • 132.keepalive
  • 133.vue-cli
  • 134.react18
  • 134.2.react18
  • 134.3.react18
  • 135.function
  • 136.toolkit
  • 137.lerna
  • 138.create-vite
  • 139.cli
  • 140.antd
  • 141.react-dnd
  • 142.1.link
  • 143.1.gulp
  • 143.2.stream
  • 143.3.gulp
  • 144.1.closure
  • 144.2.v8
  • 144.3.gc
  • 145.react-router-v6
  • 146.browser
  • 147.lighthouse
  • 148.1.basic
  • 148.2.basic
  • 148.3.basic
  • 148.4.basic
  • 148.5.basic
  • 149.1.vite
  • 149.2.vite
  • 149.3.vite
  • 149.4.vite
  • 150.react-window
  • 151.react-query
  • 152.useRequest
  • 153.transition
  • 154.emotion
  • 155.1.formily
  • 155.2.formily
  • 155.3.formily
  • 155.3.1.mobx.usage
  • 155.3.2.mobx.source
  • 156.vue-loader
  • 103.11.mf
  • 157.1.react18
  • 158.umi4
  • 159.rxjs
  • 159.rxjs2
  • 160.bff
  • 161.zustand
  • 162.vscode
  • 163.emp
  • 164.cors
  • 1.安装 dva-cli
  • 2. 生成项目
  • 3. 配置路由
  • 4. 编写登录页面
    • 4.1 编写顶部导航
    • 4.2 编写登录页面
    • 4.3 登录表单
    • 4.4 编写用户模型
    • 4.5 编写用户服务
  • 5. 编写房间列表
    • 5.1 房间列表页面
    • 5.2 编写模型
    • 5.3 房间列表服务
  • 6. 编写房间列表
    • 6.1 聊天房间组件
    • 6.2 聊天房间模型
    • 6.3 聊天表单
  • 参考

1.安装 dva-cli #

$ npm install -g dva-cli

2. 生成项目 #

dva new zfchat2 --demo
cd zfchat
npm i --registry=https://registry.npm.taobao.org
npm start

3. 配置路由 #

src\index.js

import dva from 'dva';
import { Router, Route, Switch } from 'dva/router';
import Login from './routes/Login';
import Rooms from './routes/Rooms';
import Room from './routes/Room';
import 'antd/dist/antd.css';
import user from './model/user';
import rooms from './model/rooms';
import room from './model/room';
const app = dva();

// 2. Model
// Remove the comment and define your model.
app.model(user);
app.model(rooms);
app.model(room);
// 3. Router

app.router(({ history }) =>
  <Router history={history}>
    <Switch>
      <Route path="/" exact component={Login} />
      <Route path="/rooms" exact component={Rooms} />
      <Route path="/rooms/:id" exact component={Room} />
    </Switch>
  </Router>
);

// 4. Start
app.start('#root');

4. 编写登录页面 #

4.1 编写顶部导航 #

/src/components/Header.js

import React,{Component} from 'react';
import {Layout,Menu,Icon} from 'antd';
import {Link} from 'dva/router'
import styles from './Header';
export default class Header extends Component{
    render() {
        return (
            <Layout.Header>
                    <Menu
                        theme="dark"
                        mode="horizontal"
                        defaultSelectedKeys={["home"]}
                        style={{lineHeight:'64px'}}
                    >
                        <Menu.Item key="home">
                            <Link to="/"><Icon type="home"/>首页</Link>
                        </Menu.Item>
                    </Menu>
            </Layout.Header>
        )
    }
}

4.2 编写登录页面 #

/src/routes/Login.js

import React,{Component} from 'react';
import {Layout,Row,Col} from 'antd';
import LoginForm from '../components/LoginForm';
import Header from '../components/Header';
import {connect} from 'dva';
class Login extends Component{
    render() {
        return (
            <Layout className="layout">
                <Header/>
                <Layout.Content>
                    <Row>
                        <Col offset={2} span={20}>
                            <LoginForm dispatch={this.props.dispatch}/>
                        </Col>
                    </Row>
                </Layout.Content>
            </Layout>
        )
    }
}
export default connect(
    state=>state.user
)(Login);

4.3 登录表单 #

import React,{Component} from 'react';
import {Form,Input,Button,Icon} from 'antd';
function hasErrors(fieldsError) {
    return Object.keys(fieldsError).some(field=>fieldsError[field]);
}
class LoginForm extends Component{
    componentDidMount() {
        this.props.form.validateFields();
    }
    handleSubmit=(event) => {
        event.preventDefault();
        this.props.form.validateFields((err,values) => {
            if (!err) {
                this.props.dispatch({type: 'user/login',payload: values});
                this.props.form.resetFields();
            }
        });
    }
    render() {
        let {getFieldDecorator,isFieldTouched,getFieldError,getFieldsError}=this.props.form;
        const contentError=isFieldTouched('email')&&getFieldError('email');
        return(
            <Form onSubmit={this.handleSubmit}>
                <Form.Item
                  validateStatus={contentError?'error':''}         
                  help={contentError||''}    
                >
                    {
                        getFieldDecorator('email',{type:'email',rules: [{required: true,message: '请输入邮箱'}]})(
                            <Input  prefix={<Icon type="email" style={{color:'rbga(0,0,0,.25)'}}/>} placeholder="请输入邮箱"/>
                        )
                    }
                    <Button type="primary" htmlType="submit" disabled={hasErrors(getFieldsError())}>
                      <Icon type="mail"/> 登陆    
                    </Button>
                </Form.Item>        
            </Form>
        )
    }
}
export default Form.create()(LoginForm);

4.4 编写用户模型 #

/src/models/user.js

import userService from '../service/user';
import { routerRedux } from 'dva/router';
export default {
    namespace: 'user',//命名空间
    state: {///初始状态 
        user: null
    },
    reducers: {//处理器
        user(state, action) {
            return { ...state, user: action.payload };
        }
    },
    effects: {//副作用函数 payload = user
        *login({ payload }, { put, call }) {
            const { data: token } = yield call(userService.login, payload);
            sessionStorage.setItem('token', token);
            yield put(routerRedux.push('/rooms'));
        },
        *validate(action, { put, call }) {
            const { code, data: user } = yield call(userService.validate);
            if (code == 0) {
                yield put({ type: 'user', payload: user });
            } else {
                yield put(routerRedux.push('/'));
            }
        }
    }
}

4.5 编写用户服务 #

import request from '../utils/request';
function login(data) {
    return request('http://localhost:7001/login', {
        method: 'POST',
        headers: {
            "Content-Type": "application/json"
        },
        body: JSON.stringify(data)
    });
}
function validate() {
    return request('http://localhost:7001/validate', {
        method: 'POST',
        headers: {
            "Content-Type": "application/json"
        },
        body: JSON.stringify({ token: sessionStorage.getItem('token') })
    });
}
export default {
    login,
    validate
}

5. 编写房间列表 #

5.1 房间列表页面 #

src/routes/Rooms.js

import React, { Component } from 'react';
import { Layout, Card, Row, Col, Input, Badge, Avatar, Button } from 'antd';
import { connect } from 'dva';
import { Link } from 'dva/router';
import Header from '../../components/Header';
//页面级组件一般是用来跟仓库连接 
class Rooms extends Component {
    handleChange = (event) => {
        this.props.dispatch({ type: 'rooms/changeKeyword', payload: event.target.value });
    }
    createRoom = () => {
        this.props.dispatch({ type: 'rooms/createRoom', payload: { name: this.props.keyword } });
    }
    render() {
        return (
            <Layout>
                <Header />
                <Row style={{ margin: '10px 0px' }}>
                    <Col span={24}>
                        <Input placeholder="搜索房间" onChange={this.handleChange} />
                    </Col>
                </Row>
                <Row gutter={16} style={{ margin: '10px 0px' }}>
                    {
                        this.props.rooms.map(room => (
                            <Col key={room._id} span={6} style={{ margin: '10px' }}>
                                <Link to={`/rooms/${room._id}`}>
                                    <Card
                                        title={room.name}
                                        extra={<Badge count={(room.users ? room.users.length : 0) + '人'} />}
                                    >
                                        {
                                            room.users && room.users.map(user => (
                                                <Avatar key={user.id} src={user.avatar} />
                                            ))
                                        }
                                    </Card>
                                </Link>
                            </Col>
                        ))
                    }
                </Row>
                <Row>
                    {
                        this.props.rooms.length == 0 && (
                            <Row>
                                <Col span={24} style={{ textAlign: 'center' }}>
                                    <Button type="primary" onClick={this.createRoom}>点击创建</Button>
                                </Col>
                            </Row>
                        )
                    }
                </Row>
            </Layout>
        )
    }
}
export default connect(
    state => (
        {
            keyword: state.rooms.keyword,
            rooms: state.rooms.rooms.filter(item => item.name.indexOf(state.rooms.keyword) != -1)
        }
    )
)(Rooms);

5.2 编写模型 #

src/models/rooms.js

import roomsService from '../service/rooms';
export default {
    namespace: 'rooms',
    state: {
        rooms: [],
        keyword: ''
    },
    subscriptions: {
        setup({ dispatch, history }) {
            history.listen(({ pathname }) => {
                if (pathname == '/rooms') {
                    dispatch({ type: 'user/validate' });
                    dispatch({ type: 'getAllRooms' });
                }
            });
        }
    },
    effects: {
        *getAllRooms({ }, { call, put }) {
            const { data: rooms } = yield call(roomsService.getAllRooms);
            console.log('rooms', rooms);
            yield put({ type: 'allRooms', payload: rooms });
        },
        *createRoom({ payload }, { put, call, select }) {
            const { data: room } = yield call(roomsService.createRoom, payload);
            yield put({ type: 'roomAdded', payload: room });
        }
    },
    reducers: {
        changeKeyword(state, { payload }) {
            return { ...state, keyword: payload };
        },
        allRooms(state, { payload }) {
            return { ...state, rooms: [...payload] };
        },
        roomAdded(state, { payload }) {
            return { ...state, rooms: [...state.rooms, payload] };
        }
    }
}

5.3 房间列表服务 #

src/services/rooms.js

import request from '../utils/request';
function createRoom(data) {
    return request('http://localhost:7001/createRoom', {
        method: 'POST',
        headers: {
            "Content-Type": "application/json"
        },
        body: JSON.stringify(data)
    });
}
function getAllRooms(data) {
    return request('http://localhost:7001/getAllRooms', {
        method: 'GET'
    });
}
export default {
    createRoom,
    getAllRooms
}

6. 编写房间列表 #

6.1 聊天房间组件 #

src\routes\Room\index.js

import React, { Component } from 'react';
import { connect } from 'dva';
import Header from '../../components/Header';
import { Layout, Row, Col, List, Input, Icon, Avatar } from 'antd';
import ChatForm from '../../components/ChatForm';
//页面级组件一般是用来跟仓库连接 
class Room extends Component {
    componentDidMount() {
        this.scrollToTop();
    }
    componentDidUpdate() {
        this.scrollToTop();
    }
    scrollToTop = () => {
        this.chatList.scrollTop = this.chatList.scrollHeight;
    }
    render() {
        return (
            <Layout className="layout">
                <Header />
                <Layout.Content>
                    <Row>
                        <Col offset={2} span={20}>
                            <div
                                ref={ref => this.chatList = ref}
                                style={{ maxHeight: '600px', minHeight: '300px', overflow: 'auto' }}
                            >
                                <List
                                    header={<div style={{ textAlign: 'center' }}>欢迎来到前端聊天室</div>}
                                    size="large"
                                    bordered={false}
                                    dataSource={this.props.messages}
                                    renderItem={
                                        item => (
                                            <List.Item>
                                                <List.Item.Meta
                                                    avatar={<Avatar src={item.user && item.user.avatar} />}
                                                    title={item.user && item.user.name}
                                                    description={item.user && item.user.email}
                                                />
                                                <div>{item.content}</div>
                                            </List.Item>
                                        )
                                    }
                                >
                                </List>
                            </div>
                            <ChatForm
                                dispatch={this.props.dispatch}
                                room={this.props.match.params.id} />
                        </Col>
                    </Row>
                </Layout.Content>
            </Layout>
        )
    }
}
export default connect(
    state => state.room
)(Room);

6.2 聊天房间模型 #

/src/models/room.js

import pathToRegexp from 'path-to-regexp';
import routerRedux from 'dva/router';
export default {
    namespace: 'room',
    state: {
        messages: [],
        room: ''
    },
    subscriptions: {
        setup({ dispatch, history }) {
            history.listen(({ pathname }) => {
                const match = pathToRegexp('/rooms/:id').exec(pathname);
                if (match) {
                    let room = match[1];
                    dispatch({ type: 'setRoom', payload: room });
                    dispatch({ type: 'user/validate' });
                    let io = require('socket.io-client');
                    let socket = io('http://localhost:7001', {
                        query: { token: sessionStorage.getItem('token'), room }
                    });
                    socket.on('connect', () => {
                        socket.emit('getAllMessages', room);
                    });
                    socket.on('allMessages', messages => {
                        dispatch({ type: 'allMessages', payload: messages });
                    });
                    socket.on('messageAdded', message => {
                        dispatch({ type: 'messageAdded', payload: message });
                    });
                    socket.on('online', message => {
                        dispatch({ type: 'messageAdded', payload: message });
                    });
                    socket.on('offline', message => {
                        dispatch({ type: 'messageAdded', payload: message });
                    });
                    socket.on('needLogin', message => {
                        dispatch(routerRedux.push('/'));
                    });
                    window.socket = socket;
                }
            });
        }
    },
    effects: {
        *addMessage(action, { put, call, select }) {
            const { user, room } = yield select(state => state);
            let message = action.payload;
            message.user = user.user._id;
            message.room = room.room;
            window.socket.emit('addMessage', message);
        }
    },
    reducers: {
        setRoom(state, action) {
            return { ...state, room: action.payload };
        },
        allMessages(state, action) {
            return { ...state, messages: action.payload };
        },
        messageAdded(state, action) {
            return { ...state, messages: [...state.messages, action.payload] }
        }
    }

}

6.3 聊天表单 #

src/components/ChatForm.js

import React, { Component } from 'react';
import { Form, Input, Button, Icon } from 'antd';
class ChatForm extends Component {
    componentDidMount() {
        this.props.form.validateFields();
    }
    handleSubmit = event => {
        event.preventDefault();
        this.props.form.validateFields((err, values) => {
            if (!err) {
                this.props.dispatch({ type: 'room/addMessage', payload: values });
                this.props.form.resetFields();
            }
        });
    }
    render() {
        let { getFieldDecorator, isFieldTouched, getFieldError, getFieldsError } = this.props.form;
        const contentError = isFieldTouched('content') && getFieldError('content');
        return (
            <Form onSubmit={this.handleSubmit}>
                <Form.Item
                    validateStatus={contentError ? 'error' : ''}
                    help={contentError || ''}
                >
                    {
                        getFieldDecorator('content', {
                            rules: [
                                [{ required: true, message: '请输入内容' }]
                            ]
                        })(
                            <Input
                                placeholder="请输入聊天信息"
                                prefix={<Icon type="wechat" style={{ color: 'rgba(0,0,0,.25)' }} />} />
                        )
                    }
                    <Button type="primary" htmlType="submit" disabled={contentError}>
                        <Icon type="mail" />发言
                    </Button>
                </Form.Item>
            </Form>
        )

    }
}

export default Form.create()(ChatForm);

参考 #

  • zhufengchat

访问验证

请输入访问令牌

Token不正确,请重新输入