经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » 编程经验 » 查看文章
升讯威在线客服系统的并发高性能数据处理技术：高性能OSS文件存储
来源：cnblogs　　作者：升讯威在线客服系统　　时间：2023/11/15 9:23:25　　对本文有异议

我在业余时间开发维护了一款免费开源的升讯威在线客服系统，也收获了许多用户。对我来说，只要能获得用户的认可，就是我最大的动力。

最近客服系统成功经受住了客户现场组织的压力测试，获得了客户的认可。
客户组织多名客服上线后，所有员工同一时间打开访客页面疯狂不停的给在线客服发消息，系统稳定无异常无掉线，客服回复消息正常。消息实时到达无任何延迟。

https://kf.shengxunwei.com/

我会通过一系列的文章详细分析升讯威在线客服系统的并发高性能技术是如何实现的，使用了哪些方案以及具体的做法。本文将介绍如何为多线程处理同步数据。

先看实现效果

客服端

访客端

什么是对象存储OSS

OSS具有与平台无关的RESTful API接口，您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。

您可以使用API、SDK包或者OSS迁移工具轻松地将海量数据移入或移出阿里云OSS。数据存储到OSS以后，您可以选择标准存储（Standard）作为移动应用、大型网站、图片分享或热点音视频的主要存储方式，也可以选择成本更低、存储期限更长的低频访问存储（Infrequent Access）、归档存储（Archive）、冷归档存储（Cold Archive）或者深度冷归档（Deep Cold Archive）作为不经常访问数据的存储方式。

OSS工作原理

数据以对象（Object）的形式存储在OSS的存储空间（Bucket ）中。如果要使用OSS存储数据，您需要先创建Bucket，并指定Bucket的地域、访问权限、存储类型等属性。创建Bucket后，您可以将数据以Object的形式上传到Bucket，并指定Object的文件名（Key）作为其唯一标识。

OSS以HTTP RESTful API的形式对外提供服务，访问不同地域需要不同的访问域名（Endpoint）。当您请求访问OSS时，OSS通过使用访问密钥（AccessKey ID和AccessKey Secret）对称加密的方法来验证某个请求的发送者身份。

Object操作在OSS上具有原子性和强一致性。

开始配置访问凭证

您可以选择以下类型的访问凭证。

  • 临时访问凭证：对于需要高安全性的场景，例如临时授权应用访问OSS，建议使用临时访问凭证。临时访问凭证可以限制访问的有效期，从而减少访问凭证泄露的风险。此外，临时访问凭证支持权限控制，可以有效地避免权限过大的问题。更多信息，请参见使用临时访问凭证。

  • 长期访问凭证：出于安全性考虑，不建议您使用长期访问凭证，建议您使用临时访问凭证。对于需要便利性的场景，长期访问凭证可以在较长时间内免除多次刷新的麻烦。建议每三个月更换一次长期访问凭证，以提高账号的安全性。当长期访问凭证泄露或者不再使用时，应该及时删除或者禁用相关的访问凭证，以免造成安全风险。更多信息，请参见使用长期访问凭证。

创建 OSS 存储空间

在支持资源组的地域创建存储空间时，您可以为Bucket配置资源组。关于资源组的更多信息。

  2. import com.aliyun.oss.ClientException;
  3. import com.aliyun.oss.OSS;
  4. import com.aliyun.oss.common.auth.*;
  5. import com.aliyun.oss.OSSClientBuilder;
  6. import com.aliyun.oss.OSSException;
  7. import com.aliyun.oss.model.CannedAccessControlList;
  8. import com.aliyun.oss.model.CreateBucketRequest;
  9. import com.aliyun.oss.model.DataRedundancyType;
  10. import com.aliyun.oss.model.StorageClass;
  12. public class CreateBucket {
  14.     public static void main(String[] args) throws Exception {
  15.         // yourEndpoint填写Bucket所在地域对应的Endpoint。
  16.         String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
  17.         // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
  18.         EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
  19.         // 填写Bucket名称。
  20.         String bucketName = "examplebucket";
  21.         // 填写资源组ID。如果不填写资源组ID，则创建的Bucket属于默认资源组。
  22.         //String rsId = "rg-aek27tc****";
  25.         // 创建OSSClient实例。
  26.         OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);
  28.         try {
  29.             // 创建CreateBucketRequest对象。
  30.             CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
  32.             // 如果创建存储空间的同时需要指定存储类型、存储空间的读写权限、数据容灾类型, 请参考如下代码。
  33.             // 此处以设置存储空间的存储类型为标准存储为例介绍。
  34.             //createBucketRequest.setStorageClass(StorageClass.Standard);
  35.             // 数据容灾类型默认为本地冗余存储，即DataRedundancyType.LRS。如果需要设置数据容灾类型为同城冗余存储，请设置为DataRedundancyType.ZRS。
  36.             //createBucketRequest.setDataRedundancyType(DataRedundancyType.ZRS);
  37.             // 设置存储空间读写权限为公共读，默认为私有。
  38.             //createBucketRequest.setCannedACL(CannedAccessControlList.PublicRead);
  40.             // 在支持资源组的地域创建Bucket时，您可以为Bucket配置资源组。
  41.             //createBucketRequest.setResourceGroupId(rsId);
  43.             // 创建存储空间。
  44.             ossClient.createBucket(createBucketRequest);
  45.         } catch (OSSException oe) {
  46.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  47.                     + "but was rejected with an error response for some reason.");
  48.             System.out.println("Error Message:" + oe.getErrorMessage());
  49.             System.out.println("Error Code:" + oe.getErrorCode());
  50.             System.out.println("Request ID:" + oe.getRequestId());
  51.             System.out.println("Host ID:" + oe.getHostId());
  52.         } catch (ClientException ce) {
  53.             System.out.println("Caught an ClientException, which means the client encountered "
  54.                     + "a serious internal problem while trying to communicate with OSS, "
  55.                     + "such as not being able to access the network.");
  56.             System.out.println("Error Message:" + ce.getMessage());
  57.         } finally {
  58.             if (ossClient != null) {
  59.                 ossClient.shutdown();
  60.             }
  61.         }
  62.     }
  63. }

简单上传

简单上传是指通过PutObject方法上传单个文件（Object）。简单上传包括流式上传和文件上传，流式上传使用InputStream作为OSS文件的数据源，文件上传使用本地文件作为OSS文件的数据源。本文介绍如何使用流式上传和文件上传方式上传文件。

以下代码用于将字符串上传到目标存储空间examplebucket中exampledir目录下的exampleobject.txt文件。

  2. import com.aliyun.oss.ClientException;
  3. import com.aliyun.oss.OSS;
  4. import com.aliyun.oss.common.auth.*;
  5. import com.aliyun.oss.OSSClientBuilder;
  6. import com.aliyun.oss.OSSException;
  7. import com.aliyun.oss.model.PutObjectRequest;
  8. import com.aliyun.oss.model.PutObjectResult;
  9. import java.io.ByteArrayInputStream;
  11. public class Demo {
  13.     public static void main(String[] args) throws Exception {
  14.         // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
  15.         String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
  16.         // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
  17.         EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
  18.         // 填写Bucket名称，例如examplebucket。
  19.         String bucketName = "examplebucket";
  20.         // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
  21.         String objectName = "exampledir/exampleobject.txt";
  23.         // 创建OSSClient实例。
  24.         OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);
  26.         try {
  27.             // 填写字符串。
  28.             String content = "Hello OSS，你好世界";
  30.             // 创建PutObjectRequest对象。
  31.             PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, new ByteArrayInputStream(content.getBytes()));
  33.             // 如果需要上传时设置存储类型和访问权限，请参考以下示例代码。
  34.             // ObjectMetadata metadata = new ObjectMetadata();
  35.             // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString());
  36.             // metadata.setObjectAcl(CannedAccessControlList.Private);
  37.             // putObjectRequest.setMetadata(metadata);
  38.            
  39.             // 上传字符串。
  40.             PutObjectResult result = ossClient.putObject(putObjectRequest);            
  41.         } catch (OSSException oe) {
  42.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  43.                     + "but was rejected with an error response for some reason.");
  44.             System.out.println("Error Message:" + oe.getErrorMessage());
  45.             System.out.println("Error Code:" + oe.getErrorCode());
  46.             System.out.println("Request ID:" + oe.getRequestId());
  47.             System.out.println("Host ID:" + oe.getHostId());
  48.         } catch (ClientException ce) {
  49.             System.out.println("Caught an ClientException, which means the client encountered "
  50.                     + "a serious internal problem while trying to communicate with OSS, "
  51.                     + "such as not being able to access the network.");
  52.             System.out.println("Error Message:" + ce.getMessage());
  53.         } finally {
  54.             if (ossClient != null) {
  55.                 ossClient.shutdown();
  56.             }
  57.         }
  58.     }
  59. }

简介

升讯威在线客服与营销系统是一款客服软件，但更重要的是一款营销利器。

https://kf.shengxunwei.com/

  • 可以追踪正在访问网站或使用 APP 的所有访客，收集他们的浏览情况，使客服能够主动出击，施展话术，促进成单。
    访* 客端在 PC 支持所有新老浏览器。包括不支持 WebSocket 的 IE8 也能正常使用。
  • 移动端支持所有手机浏览器、APP、各大平台的公众号对接。
  • 支持访客信息互通，可传输访客标识、名称和其它任意信息到客服系统。
  • 具备一线专业技术水平，网络中断，拔掉网线，手机飞行模式，不丢消息。同类软件可以按视频方式对比测试。

希望能够打造： 开放、开源、共享。努力打造 .net 社区的一款优秀开源产品。

钟意的话请给个赞支持一下吧，谢谢~

原文链接：https://www.cnblogs.com/sheng_chao/p/17828773.html

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

编程经验热门文章

  • Prometheus监控之SNMP Exporter介绍和数据展现
  • Intel 82599网卡异常挂死原因
  • 腾讯防水墙的分析识别与破解
  • 桌面应用自动化WinAppDriver入门
  • 文档在线预览（三）使用js前端实现word、excel、pdf、ppt 在线预览
  • 「教程」如何下载AcFun网站上的视频、A站视频下载工具
  • 基于Hi3559AV100的SVP(NNIE)开发整体流程
  • GBDT(梯度提升树)scikit-klearn中的参数说明及简汇
  • antd之RangePicker设置默认值方式
  • 决胜经典算法之插入排序

    • 编程经验推荐文章

  • wifi基础(一)：无线电波与WIFI信号干扰、衰减
  • 甲方扔给两个存在包名与类名均相同的Jar包，要在工程中同时使用怎么办？
  • 《花100块做个摸鱼小网站! 》第三篇—热搜表结构设计和热搜数据存储
  • Fluent Editor：一个基于 Quill 2.0 的富文本编辑器，功能强大、开箱即用！
  • 方法的三种调用形式
  • 《花100块做个摸鱼小网站! 》第二篇—后端应用搭建和完成第一个爬虫
  • 《熬夜整理》保姆级系列教程-玩转Wireshark抓包神器教程(4)-再识Wireshark - 北京-宏哥
  • 《软件性能测试分析与调优实践之路》(第2版) 读书笔记（二）总体介绍（下）-真正从性能分析与调优来看性能测试
  • 架构知识点（三）
  • 《花100块做个摸鱼小网站! 》第一篇—买云服务器和初始化环境

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号