异步发送

        /// <summary>
        /// 发送  改成异步发送了
        /// </summary>
        /// <param name="userList"></param>
        /// <param name="message"></param>
        /// <param name="title"></param>
        /// <param name="notifyenum"></param>
        private static void Notify(NotifyContext noticontext, List<IssuedType> notifyenum)
        {
            Task.Factory.StartNew(() =>
            {
                try
                {
                    notifyenum.ForEach(p =>
                    {
                        BaseNotifier noti = null;
                        #region 实例
                        //邮件
                        if (p == IssuedType.Mail)
                        {
                            noti = new MailNotifier();
                        }
                        //App
                        if (p == IssuedType.App)
                        {
                            noti = new AppNotifier();
                        }
                        //短信
                        if (p == IssuedType.SMS)
                        {
                            noti = new SMSNotifier();
                        }
                        #endregion

                        #region 赋值发送
                        if (noti != null)
                        {
                            noti.Context = noticontext;
                            noti.Notify();

                        }
                        #endregion
                    });
                }
                catch (Exception ex) { Dao.Get().ExecuteNonQuery("insert into vinson_msg(msg) values(‘" + ex.Message + "‘)"); }
            });
        }

原文地址:https://www.cnblogs.com/vinsonLu/p/9100779.html

时间: 2024-08-30 10:33:25

异步发送的相关文章

【demo】自己写的一个 SpringMail 异步发送邮件的demo。 javamail 邮件异步发送

原文:[demo]自己写的一个 SpringMail 异步发送邮件的demo. javamail 邮件异步发送 源代码下载地址:http://www.zuidaima.com/share/1550463483120640.htm [demo]自己写的一个 SpringMail 异步发送邮件的demo. javamail 邮件异步发送 (注意 配置里面的账号跟发件人账号要一致) 1. 请各位在跑单元测试的时候,在 spring-mail.xml 文件中配置自己的邮箱账号和密码 (我已经注释掉了)

自己实现异步发送请求和图片

异步发送比同步发送请求有不阻塞主线程和支持多线程发送请求的好处. 异步发送请求可以抽象为标准的代理对象,具有使用方便,可扩充性强,只要你足够牛可以写出比第三方控件更牛的发送模块,由于是你自己写的,可以根据自己的意愿对请求的各种细节进行处理.这个异步发送请求处理模块也是对苹果代理具体实现的经典案例. chttpsendAsynchronousRequest.h #import <Foundation/Foundation.h> @protocol chttpsendAsynchronousDel

ActiveMQ(15):Message Dispatch的消息游标与异步发送

一.消息游标 1.1 简介 ActiveMQ发送持久消息的典型处理方式是:当消息的消费者准备就绪时,消息发送系统把存储的消息按批次发送给消费者, 在发送完一个批次的消息后,指针的标记位置指向下一批次待发送消息的位置,进行后续的发送操作.这是一种比较健壮 和灵活的消息发送方式,但大多数情况下,消息的消费者不是一直处于这种理想的活跃状态. 因此,从ActiveMQ5.0.0版本开始,消息发送系统采用一种混合型的发送模式,当消息消费者处理活跃状态时,允许消息发 送系统直接把持久消息发送给消费者,当消费

Slickflow.NET 开源工作流引擎基础介绍(十)--邮件轮询异步发送模块集成

前言:在任务数据生成时,为了让办理任务的用户及时获取到待办任务的主题和内容,需要发送通知类的消息,而电子邮件和手机端的短信通知则是比较普通的消息发送.本文是针对电子邮件异步发送模块的实现来做实例说明. 1. 邮件发送通知的位置 通常任务数据生成时,就需要发送一封邮件通知,邮件内容包括正文和页面地址信息:任务办理人员在接收到邮件后,会及时登录系统进行任务处理,发送邮件通知的好处就在于方便和及时. 但是邮件发送并不是所有的业务客户都需要的一个功能,它不便于紧耦合地在引擎流转环节,即跟任务数据的生成绑

关于高并发下kafka producer send异步发送耗时问题的分析

最近开发网关服务的过程当中,需要用到kafka转发消息与保存日志,在进行压测的过程中由于是多线程并发操作kafka producer 进行异步send,发现send耗时有时会达到几十毫秒的阻塞,很大程度上上影响了并发的性能,而在后续的测试中发现单线程发送反而比多线程发送效率高出几倍.所以就对kafka API send 的源码进行了一下跟踪和分析,在此总结记录一下. 首先看springboot下 kafka producer 的使用 在config中进行配置,向IOC容器中注入DefaultKa

Java秒杀系统实战系列~整合RabbitMQ实现消息异步发送

摘要: 本篇博文是“Java秒杀系统实战系列文章”的第八篇,在这篇文章中我们将整合消息中间件RabbitMQ,包括添加依赖.加入配置信息以及自定义注入相关操作组件,比如RabbitTemplate等等,最终初步实现消息的发送和接收,并在下一篇章将其与邮件服务整合,实现“用户秒杀成功发送邮件通知消息”的功能! 内容: 对于消息中间件RabbitMQ,想必各位小伙伴没有用过.也该有听过,它是一款目前市面上应用相当广泛的消息中间件,可以实现消息异步通信.业务服务模块解耦.接口限流.消息分发等功能,在微

rocketmq的同步发送、oneway发送、异步发送怎么做的?

在sendDefaultImpl方法里面: for (; times < timesTotal; times++) { String lastBrokerName = null == mq ? null : mq.getBrokerName(); MessageQueue mqSelected = this.selectOneMessageQueue(topicPublishInfo, lastBrokerName); if (mqSelected != null) { mq = mqSelec

django使用celery异步发送短信

1. 安装celery模块 pip install -U celery==4.3.0 2. 创建celery相关目录 xiaolan/ # 项目主目录 ├── mycelery/ ├── config.py # 配置文件 ├── __init__.py ├── main.py # 主程序 └── sms/ # 一个目录可以放置多个任务,该目录下存放当前任务执行时需要的模块或依赖 └── tasks.py # 任务的文件,名称必须是这个 3. 创建celery配置文件config.py # 注意:

异步发送JavaMail

下面代码只要稍微修改几个地方就能直接使用, 亲们自取. Tips: 不要用QQ邮箱发送 JavaEmailTest : import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.S