函数式编程

为什么要学函数式编程?

  • 函数式表成是随着React的流行收到越来越多的关注(React的高阶组件使用了高阶函数来实现,高阶函数就是函数式编程的一个特性。Redux也使用了函数式编程的思想。)
  • Vue3也开始拥抱函数式编程
  • 函数式编程可以抛弃this
  • 打包过程中可以更好的利用tree shaking过滤无用代码
  • 方便测试、方便并行处理
  • 有很多库可以帮助我们进行函数式开发:lodash、underscore、ramda

什么是函数式编程?

函数式编程,缩写FP,是一种编程范式,也是一种编程风格,和面向对象是并列的关系。函数式编程我们可以认为是一种思维模式,加上实现方法。其思维方式就是把现实世界事物和事物之间的联系抽象到程序世界(是对运算过程进行抽象)
常听说的编程范式还有面向过程编程(按照步骤来实现)、面向对象编程(把现实中的事物抽象成类和对象,通过封装、继承和多态来演示不同事物之间的联系)。

函数式编程和面向对象编程的不同

从思维方式上来说,面向对象编程是对事物的抽象,而函数式编程是对运算过程的抽象

对于函数式编程思维方式的理解

  • 程序的本质:根据输入通过某种运算获得相应的输出,程序开发过程中会涉及很多输入和输出的函数。
  • 函数式编程中的函数指的不是程序中的函数Function,而是数学中的函数即映射关系,例如:y=sin(x),是这种x和y的关系
  • 相同的输入时钟要得到相同的输出(纯函数)
  • 函数式编程用描述数据(函数)之间的映射
    //非函数式
    let num1=1,
        num2=2;
    let sum=num1+num2;
    console.log(sum);

    //函数式
    function add(m,n){
        return m+n;
    };

    let sum2=add(3,4);
    console.log(sum2); 

函数式编程的前置知识

函数是一等公民

在JS中函数就是一个普通的对象,我们可以把函数存储到变量/数组中,它还可以作为另一个函数的参数和返回值,甚至我们可以在程序运行的时候通过new Function('alert(1)')来构造一个新的函数。

  • 函数可以存储在变量中:
    // 把函数赋值给变量
    let fn = function () {
        console.log("hi")
    }

    fn()

    // 一个示例
    const BlogController = {
        index (posts) { return Views.index(posts) },
        show (post) { return Views.show(post) },
        create (attrs) { return Db.create(attrs) },
        update (post, attrs) { return Db.update(post, attrs) },
        destroy (post) { return Db.destroy(post) }
    }

    // 优化 赋值的是Views的index方法,不是方法的调用
    const BlogController = {
        index: Views.index,
        show: Views.show,
        create: Db.create,
        update: Db.update,
        destroy: Db.destroy
    }
  • 函数可以作为参数

  • 函数可以作为返回值

高阶函数

高阶函数英文叫Higher-order function。JavaScript的函数其实都指向某个变量。既然变量可以指向函数,函数的参数能接收变量,那么一个函数就可以接收另一个函数作为参数,这种函数就称之为高阶函数。
在数学和计算机科学中,高阶函数是至少满足下列一个条件的函数:
1.接受一个或多个函数作为输入
2.输出一个函数

  • 函数可以作为参数
    //模拟数组中的某些操作

    // forEach
    // 定义一个遍历数组的并对每一项做处理的函数,第一个函数是一个数组,第二个参数是一个函数。
    function forEach(array,fn){
        for(let i=0;i<array.length;i++){
            fn(array[i])
        }
    };

    let arr=[1,2,3,4,5];

    forEach(arr,items=>{
        console.log(items)
    })

    // filter
    // 遍历数组,并把满足条件的元素存储成数组,再进行返回
    function filter(array,fn){
        let newArr=[];
        for(let i=0;i<array.length;i++){
            if(fn(array[i])){
                newArr.push(array[i])
            }
        };
        return newArr
    }

    let a=filter(arr,item=>item%2==0)
    console.log(a)
  • 函数做为返回值
    // test1:一个函数返回另一个函数
    function todo(){
        let text='hello world';
        return function(){
            console.log(text)
        }
    }

    //方式1 调用
    const fn=todo()
    fn()
    //方式2 调用
    todo()()

    //test2:让函数只执行一次

    function once(fn){
        let status=false;
        return function(){
            if(!status){
                status=true;
                return fn.apply(this,arguments)
            }
        }
    };

    let pay = once(function(money){
        console.log(`支付了 ${money}元`)
    })
    pay(100)
    pay(200)

使用高阶函数的意义

  • 抽象可以帮我们屏蔽细节,我们只需要知道我们的目标和解决这类问题的函数,我们不需要关心实现的细节
  • 高阶函数是用来抽象通用的问题

用高阶函数模拟常用函数

  • map:便利数组中每一个元素,然后生成新的数组
    const map=(array,fn)=>{
        let arr=[];
        for(let i of array){
            arr.push(fn(i))
        }
        return arr
    }

    let arr=[1,2,3,4,5];
    arr=map(arr,v=>v*v);
    console.log(arr)
  • every:数组中的每一个元素是否都匹配我们指定的一个条件,如果都满足返回true,如果不满足返回false
    const every=(array,fn)=>{
        let status=true;
        for(let i of array){
            status=fn(i)
            if(!status){
                break
            }
        }
        return status
    }

    let arr=[1,2,3,4,5];
    let n=every(arr,v=>v>=1);
    console.log(n)
  • some:判断数组中是否有一个元素满足我们指定的条件,满足是true,都不满足为false
    const some=(array,fn)=>{
        let status=false;
        for(let i of array){
            status=fn(i);
            if(status){
                break;
            }
        }
        return status
    }

    let arr=[4,5,6,7];
    let n=some(arr,v=>v>7);
    console.log(n);

闭包

函数在执行的时候会放到一个执行栈上,当函数执行完毕之后会从执行栈上移除。但是堆上的作用域成员因为被外部引用不能释放,因此内部函数依然可以访问外部函数的成员。闭包的核心作用就是把函数内部成员的作用范围延长

    function makeFn () {
        let msg = 'Hello function'
    }
    // 正常情况下,执行完makeFn,里面的变量msg会释放掉
    // 但是下面的情况

    function makeFn () {
        let msg = 'Hello function'
        return function () { 
            console.log(msg)
        } 
    }
    // 在上面函数中,返回了一个函数,而且在函数中还访问了原来函数内部的成员,就可以称为闭包

    const fn = makeFn()
    fn()
    // fn为外部函数,当外部函数对内部成员有引用的时候,那么内部的成员msg就不能被释放。当我们调用fn的时候,我们就会访问到msg。

    //注意的点:
    //1、我们可以在另一个作用域调用makeFn的内部函数
    //2、当我们调用内部函数的时候我们可以访问到内部成员

闭包应用

  • 计算数字的次方
    function pow(power){
        return function(number){
            return Math.pow(number,power)
        }
    }

    //求平方
    let pow2=pow(2);
    console.log(pow2(2))
    //立方
    let pow3=pow(3);
    console.log(pow3(2))
  • 计算不同级别的员工工资(不同员工基本工资相等,绩效不同)
    function peopleMoney(moeny){
        return function(value){
            return moeny+value
        }
    }

    let lv1=peopleMoney(1000);
    let lv2=peopleMoney(2000);

    console.log(lv1(200))
    console.log(lv2(1300))

纯函数

相同的输入永远会得到相同的输出,而且没有任何可观察的副作用。纯函数就类似数学中的函数(用来描述输入和输出之间的关系),如y = f(x)

    let numbers = [1, 2, 3, 4, 5] 
    // 纯函数 
    // 对于相同的函数,输出是一样的

    // slice方法,截取的时候返回截取的函数,不影响原数组
    numbers.slice(0, 3) // => [1, 2, 3] 
    numbers.slice(0, 3) // => [1, 2, 3] 
    numbers.slice(0, 3) // => [1, 2, 3] 

    // 不纯的函数 
    // 对于相同的输入,输出是不一样的

    // splice方法,返回原数组,改变原数组
    numbers.splice(0, 3) // => [1, 2, 3] 
    numbers.splice(0, 3) // => [4, 5] 
    numbers.splice(0, 3) // => []

    // 下面函数也是纯函数 
    function getSum (n1, n2) {
        return n1 + n2
    }
    console.log(getSum(1, 2)) // 3
    console.log(getSum(1, 2)) // 3
    console.log(getSum(1, 2)) // 3
  • 函数式编程不会保留计算中间的结果,所以变量是不可变的(无状态的)
  • 我们也可以把一个函数的执行结果交给另一个函数处理

Lodash——纯函数js库

Lodash是一个一致性、模块化、高性能的 JavaScript 实用工具库。

  • 安装:
    npm init -y
    npm i lodash
  • 使用:
    var _ = require('lodash');

    //数组合并
    var arr=[1,2,3]
    var newArr=_.concat(arr,[4,5,6],[7,8,9])
    console.log(newArr)

    //数组反转
    let className=['tom','bob','nike'];
    console.log(_.reserve(className))
    console.log(className)
    // 数组的翻转不是纯函数,因为会改变原数组。这里的reserve是使用了数组的reverse,所以也不是纯函数

纯函数的好处

可缓存

  • 因为对于相同的输入始终有相同的结果,那么可以把纯函数的结果缓存起来,可以提高性能。
    const _ = require('lodash');
    /* _.memoize(func, [resolver]):创建一个会缓存 func 结果的函数。 如果提供了 resolver ,就用 resolver 的返回值作为 key 缓存函数的结果。 默认情况下用第一个参数作为缓存的 key。 func 在调用时 this 会绑定在缓存函数上。*/

    //计算两个数字的和
    function add(m,n){
        console.log('once')
        return m+n
    }

    let fn=_.memoize(add);

    console.log(fn(4,5));
    console.log(fn(4,5));
    console.log(fn(4,5));
    // 输出的once只执行了一次,因为其结果被缓存下来了
  • 模拟_.memoize
    const _ = require('lodash');

    function add(m,n){
        console.log('once')
        return m+n
    }

    function memoize (f) {
        let cache = {}
        return function () {
        // arguments是一个伪数组,所以要进行字符串的转化
        let key = JSON.stringify(arguments)
        console.log(key)
        // 如果缓存中有值就把值赋值,没有值就调用f函数并且把参数传递给它
        cache[key] = cache[key] || f.apply(f,arguments)
        console.log(cache)
        return cache[key]
        }
    }
    
    let getAreaWithMemory1 = memoize(add)
    console.log(getAreaWithMemory1(4,5))
    /*  输出
        {"0":4,"1":5}
        once
        { '{"0":4,"1":5}': 9 }
        9  
    */

可测试

  • 纯函数让测试更加的方便

并行处理

  • 多线程环境下并行操作共享的内存数据很可能会出现意外情况。纯函数不需要访问共享的内存数据,所以在并行环境下可以任意运行纯函数

  • 虽然JS是单线程,但是ES6以后有一个Web Worker,可以开启一个新线程

柯里化

柯里化(Currying)是把接受多个参数的函数变换成接受一个单一参数(最初函数的第一个参数)的函数,并且返回接受余下的参数且返回结果的新函数的技术。 当函数有多个参数的时候,我们可以对函数进行改造。我们可以调用一个函数,只传递部分的参数(这部分参数以后永远不变),然后让这个函数返回一个新的函数。新的函数传递剩余的参数,并且返回相应的结果。

    // 下面这段代码是解决了不纯的函数的问题,但是里面出现了硬编码
    function checkAge (age) { 
        let mini = 18
        return age >= mini 
    }


    // 普通的纯函数
    function checkAge (min, age) {
        return age >= min
    }
    console.log(checkAge(18, 20))  //true
    console.log(checkAge(18, 24))  //true
    console.log(checkAge(20, 24))  //true
    // 经常使用18,这段代码是重复的。避免重复
    function checkAge (min) {
        return function (age) {
            return age >= min
        }
    }

    let checkAge18 = checkAge(18)
    let checkAge20 = checkAge(20)

    console.log(checkAge18(20)) //true
    console.log(checkAge18(24)) //true

Lodash中的柯里化 —— curry()

  • 功能:创建一个函数,该函数接收一个或多个 func的参数,如果 func 所需要的参数都被提供则执行 func 并返回执行的结果。否则继续返回该函数并等待接收剩余的参数。
  • 参数:需要柯里化的函数
  • 返回值:柯里化后的函数
    //案例
    const _ = require('lodash');
    function getSum(a,b,c){
        return a+b+c
    }

    const curried=_.curry(getSum)

    console.log(curried(1,2,3))
    console.log(curried(1)(2)(3))
    console.log(curried(1)(2,3))

柯里化的实现

  • 实现一个柯里化转换函数要进行分析

1.入参出参:调用传递一个纯函数的参数,完成之后返回一个柯里化函数

2.入参情况分析:

  • 如果curried调用传递的参数和getSum函数参数个数相同,那么立即执行并返回调用结果

  • 如果curried调用传递的参数是getSum函数的部分参数,那么需要返回一个新的函数,并且等待接收getSum的其他参数

3 重点关注:

  • 获取调用的参数
  • 判断个数是否相同

    function getSum (a, b, c) {
         return a + b + c
    }

    // 模拟柯里化函数
    function curry (func) {
    // 取名字是为了下面实参小于形参的时候用的
    return function curriedFn(...args) {
        // 判断实参和形参的个数
        if(args.length < func.length) {
        return function() {
            // 等待传递的剩余参数,如果剩余函数的参数加上之前的参数等于形参,那么就返回func
            // 第一部分参数在args里面,第二部分参数在arguments里面,要将两个合并并且展开传递(使用...)
            // concat函数要合并两个数组,arguments为伪数组,所以用Array.from进行转换
            return curriedFn(...args.concat(Array.from(arguments)))
        }
        }
        // 如果实参大于等于形参的个数
        // args是剩余参数,是个数组形式,而返回的时候要展开(使用...)
        return func(...args)
    }
    }


    // test
    const curriedTest = curry(getSum)

    console.log(curriedTest(1, 2, 3))  // 6
    console.log(curriedTest(1)(2, 3))  // 6
    console.log(curriedTest(1, 2)(3))  // 6

总结

  • 柯里化可以让我们给一个函数传递较少的参数得到一个已经记住了某些固定参数的新函数(比如match函数新生成了haveSpace函数,里面使用了闭包,记住了我们给传递的正则表达式的参数)
  • 这是一种对函数参数的'缓存'(使用了闭包)
  • 让函数变的更灵活,让函数的粒度更小
  • 可以把多元函数转换成一元函数,可以组合使用函数产生强大的功能

函数组合

如果一个函数要经过多个函数处理才能得到最终值,这个时候可以把中间过程的函数合并成一个函数。函数组合默认是从右到左执行

    //例子:有一个数组,需要获取到数组最后一个元素
    function reverse(array){
        return array.reverse()
    }

    function first(array){
        return array[0]
    }

    //es5

    /* function getFirst(f,n){
        return function(value){
            return f(n(value))
        }
    }
    */

    //es6
    const getFirst=(f,n)=>value=>f(n(value));

    let compose=getFirst(first,reverse);

    console.log(compose([1,2,3,4,5]))  //5

组合函数模拟

  • 有一个数组,需要获取到数组中最后一个元素并换成大写
    const reverse = arr => arr.reverse();
    const first = arr => arr[0];
    const toUpper = s => s.toUpperCase();

    function compose (...args) {
    // 返回的函数,有一个传入的初始参数即value
    return function (value) {
        // ...args是执行的函数的数组,从右向左执行那么数组要进行reverse翻转
        // reduce: 对数组中的每一个元素,去执行我们提供的一个函数,并将其汇总成一个单个结果
        // reduce的第一个参数是一个回调函数,第二个参数是acc的初始值,这里acc的初始值就是value

        // reduce第一个参数的回调函数需要两个参数,第一个参数是汇总的一个结果,第二个参数是如果处理汇总的结果的函数并返回一个新的值
        // fn指的是数组中的每一个元素(即函数),来处理参数acc,完成之后下一个数组元素处理的是上一个数组的结果acc
        return args.reverse().reduce(function (acc, fn) {
        return fn(acc)
        }, value)
    }
    }


    //test
    const fTest = compose(toUpper, first, reverse)
    console.log(fTest(['one', 'two', 'three'])) // THREE


    // ES6的写法(函数都变成箭头函数)
    const compose = (...args) => value => args.reverse().reduce((acc, fn) => fn(acc), value)

函数组合-结合律

什么是函数组合结合律?

  • 下面三个情况结果一样,我们既可以把 g 和 h 组合,还可以把 f 和 g 组合
    //伪代码
    // 结合律(associativity) 
    let f = compose(f, g, h) 
    let associative = compose(compose(f, g), h) == compose(f, compose(g, h)) 
    // true
  • 实际案例
    const _ = require('lodash');
    // 方式一
    const f = _.flowRight(_.toUpper, _.first, _.reverse)
    // 方式二
    const f = _.flowRight(_.flowRight(_.toUpper, _.first), _.reverse)
    // 方式三
    const f = _.flowRight(_.toUpper, _.flowRight(_.first,  _.reverse))

    // 无论上面那种写法,下面都输出THREE这个相同的结果
    console.log(f(['one', 'two', 'three'])) // THREE

如何测试函数组合

如果我们运行的结果和我们的预期不一致,我们怎么调试呢?我们怎么能知道中间运行的结果呢?

  • 下面这个输入NEVER SAY DIE要对应输出nerver-say-die
    const _ = require('lodash')

    // 这里split函数需要传入两个参数,且我们最后调用的时候要传入字符串,所以字符串要在第二个位置传入,这里我们需要自己封装一个split函数
    // _.split(string, separator)

    // 将多个参数转成一个参数,用到函数的柯里化
    const split = _.curry((sep, str) => _.split(str, sep))

    // 大写变小写,用到toLower(),因为这个函数只有一个参数,所以可以在函数组合中直接使用

    // 这里join方法也需要两个参数,第一个参数是数组,第二个参数是分隔符,数组也是最后的时候才传递,也需要交换
    const join = _.curry((sep, array) => _.join(array, sep))

    const f = _.flowRight(join('-'), _.toLower, split(' '))

    console.log(f('NEVER SAY DIE')) //n-e-v-e-r-,-s-a-y-,-d-i-e

但是最后的结果却不是我们想要的,那么我们怎么调试呢?


    // NEVER SAY DIE --> nerver-say-die

    const _ = require('lodash')
    
    const split = _.curry((sep, str) => _.split(str, sep))
    const join = _.curry((sep, array) => _.join(array, sep))

    // 我们需要对中间值进行打印,并且知道其位置,用柯里化输出一下
    const log = _.curry((tag, v) => {
        console.log(tag, v)
        return v
    })

    // 从右往左在每个函数后面加一个log,并且传入tag的值,就可以知道每次结果输出的是什么
    const f = _.flowRight(join('-'), log('after toLower:'), _.toLower, log('after split:'), split(' '))
    // 从右到左
    //第一个log:after split: [ 'NEVER', 'SAY', 'DIE' ] 正确
    //第二个log: after toLower: never,say,die  转化成小写字母的时候,同时转成了字符串,这里出了问题
    console.log(f('NEVER SAY DIE')) //n-e-v-e-r-,-s-a-y-,-d-i-e


    // 修改方式,利用数组的map方法,遍历数组的每个元素让其变成小写 
    // 这里的map需要两个参数,第一个是数组,第二个是回调函数,需要柯里化
    const map = _.curry((fn, array) => _.map(array, fn))

    const f1 = _.flowRight(join('-'), map(_.toLower), split(' '))
    console.log(f1('NEVER SAY DIE')) // never-say-die

FP模块

函数组合的时候用到很多的函数需要柯里化处理,我们每次都处理那些函数有些麻烦,所以lodash中有一个FP模块

  • lodash 的 fp 模块提供了实用的对函数式编程友好的方法

  • 提供了不可变 auto-curried iteratee-first data-last (函数之先,数据之后)的方法

    const fp=require('lodash/fp');

    // 函数置先,数据置后
    console.log(fp.map(fp.toUpper,['a','b','c','d']))

    //规则置前,数据置后

    console.log(fp.split(' ')('hello word'))
    console.log(fp.split(' ','hello word'))

Point Free

Point Free是一种编程风格,具体的实现是函数的组合。Point Free: 我们可以把数据处理的过程定义成与数据无关的合成运算,不需要用到代表数据的那个参数,只要把简单的运算步骤合成到一起,在使用这种模式之前我们需要定义一些辅助的基本运算函数。

  • 不需要指明处理的数据

  • 只需要合成运算过程

  • 需要定义一些辅助的基本运算函数

  • 例子1

    /*将Hello   World 转化为 hello_world  */
    const fp=require('lodash/fp');

    const f=fp.flowRight(fp.replace(/\s+/g,'_'),fp.toLower);

    console.log(f('Hello World')) //hello_world 
  • 例子2
    //world wild web -->W. W. W
    //思路:
    //把一个字符串中的额首字母提取并转换成大写,使用. 作为分隔符
    const fp = require('lodash/fp')

    const firstLetterToUpper = fp.flowRight(fp.join('. '), fp.map(fp.first), fp.map(fp.toUpper), fp.split(' '))
    console.log(firstLetterToUpper('world wild web')) //W. W. W

    // 上面的代码进行了两次的遍历,性能较低
    // 优化
    const firstLetterToUpper = fp.flowRight(fp.join('. '), fp.map(fp.flowRight(fp.first, fp.toUpper)), fp.split(' '))
    console.log(firstLetterToUpper('world wild web')) //W. W. W

Functor

为什么要学函子?

函子(representative functor)是范畴论里的概念,指从任意范畴到集合范畴的一种特殊函子。
我们没有办法避免副作用,但是我们尽可能的将副作用控制在可控的范围内,我们可以通过函子去处理副作用,我们也可以通过函子去处理异常,异步操作等。

什么是Functor

  • 容器:包含值和值的变形关系(这个变形关系就是函数)

  • 函子:是一个特殊的容器,通过一个普通的对象来实现,该对象具有 map 方法,map方法可以运行一个函数对值进行处理(变形关系)

    class Container{
        constructor(value){
            // 这个函子的值是保存在内部的,不对外公布
            // _下划线的成员都是私有成员,外部无法访问,值是初始化的传的参数
            this._value=value
        }
        //有一个对外的方法map,接收一个函数(纯函数),来处理这个值
        map(fn){
            // 返回一个新的函子,把fn处理的值返回给函子,由新的函子来保存
            return new Container(fn(this._value))
        }
    }
    // 创建一个函子的对象
    let r=new Container(5)
            .map(n=>n+1)
            .map(n=>n*n)

    // 返回了一个container函子对象,里面有值是36,不对外公布
    console.log(r) //Container { _value: 36 }
  • 上面还是面向对象的编程思想,要修改成函数式编程的思想,需要避免使用new
    class Container {
    //使用类的静态方法,of替代了new Container的作用
    static of (value) {
        return new Container(value)
    }
    constructor (value) {
        this._value = value
    }
    
    map (fn) {
        return Container.of(fn(this._value))
    }
    }

    const r = Container.of(5)
                .map(x=>x+2) // 7
                .map(x=> x**2) // 49

    console.log(r) // Container { _value: 49 }

总结

  • 函数式编程的运算不直接操作值,而是由函子完成
  • 函子就是一个实现了 map 契约的对象
  • 我们可以把函子想象成一个盒子,这个盒子里封装了一个值
  • 想要处理盒子中的值,我们需要给盒子的 map 方法传递一个处理值的函数(纯函数),由这个函数来对值进行处理
  • 最终 map 方法返回一个包含新值的盒子(函子)

  • 遗留问题:在上面说的函子中,如果value是null undefined,怎么办?
    Container.of(null)
    .map(x=>x.toUpper) // 报错,使得函数不纯
  • 下面这些函子就是处理不同问题的函数

MyBe函子

MayBe 函子的作用就是可以对外部的空值情况做处理(控制副作用在允许的范围)

    class MayBe {
    static of (value) {
        return new MayBe(value)
    }
    constructor (value) {
        this._value = value
    }

    map(fn) {
        // 判断一下value的值是不是null和undefined,如果是就返回一个value为null的函子,如果不是就执行函数
        return this.isNothing() ? MayBe.of(null) : MayBe.of(fn(this._value))
    }

    // 定义一个判断是不是null或者undefined的函数,返回true/false
    isNothing() {
        return this._value === null || this._value === undefined
    }
    }

    const r = MayBe.of('hello world')
    .map(x => x.toUpperCase())

    console.log(r) //MayBe { _value: 'HELLO WORLD' }


    // 如果输入的是null,是不会报错的
    const rnull = MayBe.of(null)
    .map(x => x.toUpperCase())
    console.log(rnull) //MayBe { _value: null }
  • 但是这里有一个问题就是,如果map中间有好几步,最后返回是null,并不知道是哪一个步骤返回的。解决这个问题,需要看下一个函子。

Either函子

  • Either 两者中的任何一个,类似于 if...else...的处理
  • 当出现问题的时候,Either函子会给出提示的有效信息,
  • 异常会让函数变的不纯,Either 函子可以用来做异常处理
// 因为是二选一,所以要定义left和right两个函子

class Left {
  static of (value) {
    return new Left(value)
  }

  constructor (value) {
    this._value = value
  }

  map (fn) {
    return this
  }
}

class Right {
  static of (value) {
    return new Right(value)
  }

  constructor (value) {
    this._value = value
  }

  map (fn) {
    return Right.of(fn(this._value))
  }
}

let r1 = Right.of(12).map(x => x + 2)
let r2 = Left.of(12).map(x => x + 2)
console.log(r1) // Right { _value: 14 }
console.log(r2) // Left { _value: 12 }
// 为什么结果会不一样?因为Left返回的是当前对象,并没有使用fn函数

// 那么这里如何处理异常呢?
// 我们定义一个字符串转换成对象的函数
function parseJSON(str) {
  // 对于可能出错的环节使用try-catch
  // 正常情况使用Right函子
  try{
    return Right.of(JSON.parse(str))
  }catch (e) {
  // 错误之后使用Left函子,并返回错误信息
    return Left.of({ error: e.message })
  }
}

let rE = parseJSON('{name:xm}')
console.log(rE) // Left { _value: { error: 'Unexpected token n in JSON at position 1' } }
let rR = parseJSON('{"name":"xm"}')
console.log(rR) // Right { _value: { name: 'xm' } }

console.log(rR.map(x => x.name.toUpperCase())) // Right { _value: 'XM' }

IO函子

  • IO就是输入输出,IO 函子中的 _value 是一个函数,这里是把函数作为值来处理

  • IO 函子可以把不纯的动作存储到 _value 中,延迟执行这个不纯的操作(惰性执行),包装当前的操

  • 把不纯的操作交给调用者来处理

因为IO函数需要用到组合函数,所以需要提前安装Lodash

    npm init -y
    npm i lodash
    const fp = require('lodash/fp')

    class IO {
    // of方法快速创建IO,要一个值返回一个函数,将来需要值的时候再调用函数
    static of(value) {
        return new IO(() => value)
    }
    // 传入的是一个函数
    constructor (fn) {
        this._value = fn
    }

    map(fn) {
        // 这里用的是new一个新的构造函数,是为了把当前_value的函数和map传入的fn进行组合成新的函数
        return new IO(fp.flowRight(fn, this._value))
    }
    }


    // test
    // node执行环境可以传一个process对象(进程)
    // 调用of的时候把当前取值的过程包装到函数里面,再在需要的时候再获取process
    const r = IO.of(process)
    // map需要传入一个函数,函数需要接收一个参数,这个参数就是of中传递的参数process
    // 返回一下process中的execPath属性即当前node进程的执行路径
    .map(p => p.execPath)
    console.log(r) // IO { _value: [Function] }


    // 上面只是组合函数,如果需要调用就执行下面
    console.log(r._value()) // /usr/local/bin/node

Task函子(异步执行)

  • 函子可以控制副作用,还可以处理异步任务,为了避免地狱之门。

  • 异步任务的实现过于复杂,我们使用 folktale 中的 Task 来演示

  • folktale 一个标准的函数式编程库。和 lodash、ramda 不同的是,他没有提供很多功能函数。只提供了一些函数式处理的操作,例如:compose、curry 等,一些函子 Task、Either、 MayBe 等

folktale的安装

    npm i folktale

folktale中的curry函数

    const {curry } = require('folktale/core/lambda');

    // curry中的第一个参数是函数有几个参数,为了避免一些错误
    const f = curry(2, (x, y) => x + y)

    console.log(f(1, 2)) // 3
    console.log(f(1)(2)) // 3

folktale中的compose函数

    const { compose, curry } = require('folktale/core/lambda')
    const { toUpper, first } = require('lodash/fp')

    // compose 组合函数在lodash里面是flowRight
    const r = compose(toUpper, first)
    console.log(r(['one', 'two']))  // ONE

Task函子异步执行

  • folktale(2.3.2) 2.x 中的 Task 和 1.0 中的 Task 区别很大,1.0 中的用法更接近我们现在演示的
    函子

  • 这里以 2.3.2 来演示

    const { task } = require('folktale/concurrency/task')
    const fs = require('fs')
    // 2.0中是一个函数,函数返回一个函子对象
    // 1.0中是一个类

    //读取文件
    function readFile (filename) {
    // task传递一个函数,参数是resolver
    // resolver里面有两个参数,一个是reject失败的时候执行的,一个是resolve成功的时候执行的
    return task(resolver => {
        //node中读取文件,第一个参数是路径,第二个是编码,第三个是回调,错误在先
        fs.readFile(filename, 'utf-8', (err, data) => {
        if(err) resolver.reject(err)
        resolver.resolve(data)
        })
    })
    }

    //演示一下调用
    // readFile调用返回的是Task函子,调用要用run方法
    readFile('package.json')
    .run()
    // 现在没有对resolve进行处理,可以使用task的listen去监听获取的结果
    // listen传一个对象,onRejected是监听错误结果,onResolved是监听正确结果
    .listen({
        onRejected: (err) => {
        console.log(err)
        },
        onResolved: (value) => {
        console.log(value)
        }
    })
    
    /** {
        "name": "Functor",
        "version": "1.0.0",
        "description": "",
        "main": "either.js",
        "scripts": {
        "test": "echo \"Error: no test specified\" && exit 1"
        },
        "keywords": [],
        "author": "",
        "license": "ISC",
        "dependencies": {
        "folktale": "^2.3.2",
        "lodash": "^4.17.20"
        }
    }
    */
  • 案例
    const { task } = require('folktale/concurrency/task')
    const fs = require('fs')
    const { split, find } = require('lodash/fp')
    // 2.0中是一个函数,函数返回一个函子对象
    // 1.0中是一个类

    //读取文件
    function readFile (filename) {
    // task传递一个函数,参数是resolver
    // resolver里面有两个参数,一个是reject失败的时候执行的,一个是resolve成功的时候执行的
    return task(resolver => {
        //node中读取文件,第一个参数是路径,第二个是编码,第三个是回调,错误在先
        fs.readFile(filename, 'utf-8', (err, data) => {
        if(err) resolver.reject(err)
        resolver.resolve(data)
        })
    })
    }

    //演示一下调用
    // readFile调用返回的是Task函子,调用要用run方法
    readFile('package.json')
    //在run之前调用map方法,在map方法中会处理的拿到文件返回结果
    // 在使用函子的时候就没有必要想的实现机制
    .map(split('\n'))
    .map(find(x => x.includes('version')))
    .run()
    // 现在没有对resolve进行处理,可以使用task的listen去监听获取的结果
    // listen传一个对象,onRejected是监听错误结果,onResolved是监听正确结果
    .listen({
        onRejected: (err) => {
        console.log(err)
        },
        onResolved: (value) => {
        console.log(value) // "version": "1.0.0",
        }
    })

Pointed函子

  • Pointed函子是实现了of静态方法的函子
  • of方法是为了避免使用new来创建对象,更深层的含义是of方法用来把值放到上下文
  • Context(把值放到容器中,使用 map 来处理值)
    class Container { 
    // Point函子
    // 作用是把值放到一个新的函子里面返回,返回的函子就是一个上下文
        static of (value) { 
            return new Container(value)
        }
        ……  
    }

    // 调用of的时候获得一个上下文,之后是在上下文中处理数据
    Contanier.of(2)
    .map(x => x + 5)

Monad函子(单子)

  • IO函子的嵌套问题,用来解决IO函子多层嵌套的一个问题
const fp = require('lodash/fp')
const fs = require('fs')

class IO {
  static of (value) {
    return new IO(() => {
      return value
    })
  }
  constructor (fn) {
    this._value = fn
  }

  map(fn) {
    return new IO(fp.flowRight(fn, this._value))
  }
}

//读取文件函数
let readFile = (filename) => {
  return new IO(() => {
    //同步获取文件
    return fs.readFileSync(filename, 'utf-8')
  })
}

//打印函数
// x是上一步的IO函子
let print = (x) => {
  return new IO(()=> {
    console.log(x)
    return x
  })
}

// 组合函数,先读文件再打印
let cat = fp.flowRight(print, readFile)
// 调用
// 拿到的结果是嵌套的IO函子 IO(IO(x))
let r = cat('package.json')
console.log(r) 
// IO { _value: [Function] }
console.log(cat('package.json')._value()) 
// IO { _value: [Function] }
// IO { _value: [Function] }
console.log(cat('package.json')._value()._value())
// IO { _value: [Function] }
/**
 * {
  "name": "Functor",
  "version": "1.0.0",
  "description": "",
  "main": "either.js",
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1"
  },
  "keywords": [],
  "author": "",
  "license": "ISC",
  "dependencies": {
    "folktale": "^2.3.2",
    "lodash": "^4.17.20"
  }
}
 */
  • 上面遇到多个IO函子嵌套的时候,那么_value就会调用很多次,这样的调用体验很不好。所以进行优化。

  • Monad 函子是可以变扁的 Pointed 函子,用来解决IO函子嵌套问题,IO(IO(x))

  • 一个函子如果具有 join 和 of 两个方法并遵守一些定律就是一个 Monad

实现一个Monad函子

const fp = require('lodash/fp')
const fs = require('fs')

class IO {
  static of (value) {
    return new IO(() => {
      return value
    })
  }
  constructor (fn) {
    this._value = fn
  }

  map(fn) {
    return new IO(fp.flowRight(fn, this._value))
  }

  join () {
    return this._value()
  }

  // 同时调用map和join方法
  flatMap (fn) {
    return this.map(fn).join()
  }
}

let readFile = (filename) => {
  return new IO(() => {
    return fs.readFileSync(filename, 'utf-8')
  })
}

let print = (x) => {
  return new IO(()=> {
    console.log(x)
    return x
  })
}

let r = readFile('package.json')
          .flatMap(print)
          .join()     
// 执行顺序
/**
 * readFile读取了文件,然后返回了一个IO函子
 * 调用flatMap是用readFile返回的IO函子调用的
 * 并且传入了一个print函数参数
 * 调用flatMap的时候,内部先调用map,当前的print和this._value进行合并,合并之后返回了一个新的函子
 * (this._value就是readFile返回IO函子的函数:
 *      () => {
          return fs.readFileSync(filename, 'utf-8')
        }
 * )
 * flatMap中的map函数执行完,print函数返回的一个IO函子,里面包裹的还是一个IO函子
 * 下面调用join函数,join函数就是调用返回的新函子内部的this._value()函数
 * 这个this._value就是之前print和this._value的组合函数,调用之后返回的就是print的返回结果
 * 所以flatMap执行完毕之后,返回的就是print函数返回的IO函子
 *  */
 
 r = readFile('package.json')
        // 处理数据,直接在读取文件之后,使用map进行处理即可
        .map(fp.toUpper)
        .flatMap(print)
        .join()  

// 读完文件之后想要处理数据,怎么办?
// 直接在读取文件之后调用map方法即可

/**
 * {
  "NAME": "FUNCTOR",
  "VERSION": "1.0.0",
  "DESCRIPTION": "",
  "MAIN": "EITHER.JS",
  "SCRIPTS": {
    "TEST": "ECHO \"ERROR: NO TEST SPECIFIED\" && EXIT 1"
  },
  "KEYWORDS": [],
  "AUTHOR": "",
  "LICENSE": "ISC",
  "DEPENDENCIES": {
    "FOLKTALE": "^2.3.2",
    "LODASH": "^4.17.20"
  }
}
 */