基于MATLAB的协同过滤推荐算法实现

基于MATLAB的协同过滤推荐算法实现，包含用户-用户和物品-物品两种主流方法

一、核心代码实现

function collaborative_filtering_demo()
    %% 数据加载与预处理
    data = load('ml-100k/u.data'); % 加载MovieLens数据集
    [user_num, item_num] = deal(943, 1682);
    ratings = sparse(data(:,1), data(:,2), data(:,3), user_num, item_num);

    % 数据标准化
    user_mean = full(mean(ratings, 2));
    ratings_norm = ratings - user_mean*ones(1,item_num);

    %% 参数设置
    k = 50; % 最近邻数量
    sim_method = 'cosine'; % 相似度计算方法：'pearson'/'cosine'/'jaccard'

    %% 用户-用户协同过滤
    tic;
    [user_sim, user_ratings] = user_cf(ratings_norm, k, sim_method);
    pred_user = predict_ratings(user_ratings, user_sim);
    time_user = toc;

    %% 物品-物品协同过滤
    tic;
    [item_sim, item_ratings] = item_cf(ratings_norm, k, sim_method);
    pred_item = predict_ratings(item_ratings, item_sim);
    time_item = toc;

    %% 性能评估
    [rmse_user, mae_user] = evaluate(ratings, pred_user);
    [rmse_item, mae_item] = evaluate(ratings, pred_item);

    %% 结果展示
    fprintf('用户-用户 CF: RMSE=%.4f, MAE=%.4f, 耗时=%.2fs\n', rmse_user, mae_user, time_user);
    fprintf('物品-物品 CF: RMSE=%.4f, MAE=%.4f, 耗时=%.2fs\n', rmse_item, mae_item, time_item);

    % 可视化推荐结果
    figure;
    subplot(1,2,1);
    imshow(imadjust(mat2gray(pred_user(1,:))));
    title('用户-用户推荐评分热力图');

    subplot(1,2,2);
    imshow(imadjust(mat2gray(pred_item(:,1))));
    title('物品-物品推荐评分热力图');
end

%% 用户-用户协同过滤
function [sim_matrix, ratings_matrix] = user_cf(ratings, k, method)
    [user_num, item_num] = size(ratings);
    sim_matrix = zeros(user_num, user_num);

    % 计算相似度矩阵
    for i = 1:user_num
        for j = i+1:user_num
            common = sum(ratings(i,:) & ratings(j,:)');
            if common == 0
                sim = 0;
            else
                switch method
                    case 'pearson'
                        sim = corr(ratings(i,:), ratings(j,:)');
                    case 'cosine'
                        sim = dot(ratings(i,:), ratings(j,:)') / ...
                              (norm(ratings(i,:)) * norm(ratings(j,:)));
                    case 'jaccard'
                        sim = common / (sum(ratings(i,:) | ratings(j,:)'));
                end
            end
            sim_matrix(i,j) = sim;
            sim_matrix(j,i) = sim;
        end
    end

    % 预测评分
    ratings_matrix = zeros(size(ratings));
    for i = 1:user_num
        [~, idx] = sort(sim_matrix(i,:), 'descend');
        neighbors = idx(2:k+1); % 排除自身
        ratings_matrix(i,:) = mean(ratings(neighbors,:), 1);
    end
end

%% 物品-物品协同过滤
function [sim_matrix, ratings_matrix] = item_cf(ratings, k, method)
    [user_num, item_num] = size(ratings);
    sim_matrix = zeros(item_num, item_num);

    % 计算相似度矩阵
    for i = 1:item_num
        for j = i+1:item_num
            common = sum(ratings(:,i) & ratings(:,j)');
            if common == 0
                sim = 0;
            else
                switch method
                    case 'pearson'
                        sim = corr(ratings(:,i), ratings(:,j)');
                    case 'cosine'
                        sim = dot(ratings(:,i), ratings(:,j)') / ...
                              (norm(ratings(:,i)) * norm(ratings(:,j)));
                    case 'jaccard'
                        sim = common / (sum(ratings(:,i) | ratings(:,j)'));
                end
            end
            sim_matrix(i,j) = sim;
            sim_matrix(j,i) = sim;
        end
    end

    % 预测评分
    ratings_matrix = zeros(size(ratings));
    for j = 1:item_num
        [~, idx] = sort(sim_matrix(j,:), 'descend');
        neighbors = idx(2:k+1); % 排除自身
        ratings_matrix(:,j) = mean(ratings(:,neighbors), 2);
    end
end

%% 评分预测与评估
function pred = predict_ratings(ratings, sim_matrix)
    [user_num, item_num] = size(ratings);
    pred = zeros(size(ratings));

    for i = 1:user_num
        for j = 1:item_num
            if ratings(i,j) == 0
                neighbors = find(sim_matrix(i,:) > 0);
                if ~isempty(neighbors)
                    weights = sim_matrix(i,neighbors);
                    pred(i,j) = sum(weights .* mean(ratings(neighbors,:),1)(j)) / sum(abs(weights));
                end
            else
                pred(i,j) = ratings(i,j);
            end
        end
    end
end

function [rmse, mae] = evaluate(true_ratings, pred_ratings)
    valid = true_ratings > 0;
    rmse = sqrt(mean((true_ratings(valid) - pred_ratings(valid)).^2));
    mae = mean(abs(true_ratings(valid) - pred_ratings(valid)));
end

二、关键功能说明

1. 数据预处理

• 数据加载：支持MovieLens等标准数据集
• 稀疏矩阵存储：处理大规模数据（943用户×1682电影）
• 评分标准化：消除用户评分偏差

2. 预测策略

• 加权平均：基于K近邻的相似度加权
• 冷启动处理：新用户/物品采用全局平均值

3. 性能评估

• RMSE：均方根误差（反映预测精度）
• MAE：平均绝对误差（反映稳定性）
• 计算耗时：算法效率评估

三、性能优化方案

四、应用场景扩展

1. 电影推荐：基于用户评分预测未观看电影
2. 电商推荐：商品相似度驱动的关联推荐
3. 社交网络：用户兴趣社区发现
4. 内容推荐：基于文章/视频内容的相似推荐

参考代码 协同过滤推荐算法 www.youwenfan.com/contentalg/98289.html

五、改进方向建议

1. 混合推荐：结合内容特征与协同过滤
2. 实时推荐：增量更新相似度矩阵
3. 深度学习融合：使用Autoencoder优化特征表示
4. 多目标优化：同时优化准确率和多样性指标

六、数据集

• MovieLens 100K：包含943用户对1682部电影的10万条评分
• Amazon Product Data：商品评论与评分数据
• 豆瓣电影数据：中文影评数据集