标签: multicast

SSIS:使用多播将数据输入到 2 个相关目的地

我是 SSIS 新手。我的数据来自单一来源。我需要将该数据输入到几个表中(这些表通过外键关系相关)。我正在使用多播将数据输入到多个目的地。

我的问题是...

如何获取一个目的地的条目的标识并将该标识用于第二个目的地的外键列?

这是我正在寻找的示例。Employee 表有一个指向 Address 表的外键。但来源包含所有这些信息。将数据输入两个不同的位置很容易。但是,当我将信息输入“员工”表时,我需要“地址”表中的身份。我如何获得该 ID?

来源(Excel 文件)

Name        Street           State        etc...
----        ------           -----
Jim         12345 Plain St.  CA
Bob         54321 Main St.   CA
etc.
Run Code Online (Sandbox Code Playgroud)

目的地

   Address        Employee
   -------        -------
PK AddressId   PK EmployeeId
   Street      FK AddressId
   State          Name
   etc...         etc...
Run Code Online (Sandbox Code Playgroud)

sql ssis multicast

5
推荐指数
1
解决办法
4994
查看次数

加入 igmp_group 无法在 lightwight IP (lwip) 中工作

我是 lwip 的新手,我想用 lwip 创建一个多播接收器。我的步骤如下: 1.启用LWIP_IGMP;2、在low_level_init()中设置NETIF_FLAG_IGMP;3、加入组播组,创建并绑定pcb;4. udp_connect到remote_ip(或多播IP地址?都尝试过但失败)

加入组返回成功,当程序执行此操作时,一切看起来都很好。然而组播接收器不工作,没有组播数据进入网络接口。看来我实际上并没有将我的接收者加入到 igmp 组,尽管加入过程看起来不错。有人知道我错过了什么吗?

我在igmp_joingroup()中发现“netif->igmp_mac_filter != NULL”,但是这个回调被设置为NULL并且没有实现。我是否需要自己实现来设置 MAC 过滤器,或者将其保留为 NULL 就可以了?

非常感谢你的帮助!

瑞安

multicast igmp lwip

5
推荐指数
1
解决办法
4100
查看次数

Netlink 多播内核组

我想要实现的任务实际上非常简单(将字符串“TEST”多播到用户态守护程序),但内核模块无法编译。它因错误而停止:

\n\n
passing argument 4 of \xe2\x80\x98genlmsg_multicast_allns\xe2\x80\x99 makes integer from pointer without a cast [enabled by default]\n
Run Code Online (Sandbox Code Playgroud)\n\n

但不应该只是我定义的多播组吗?

\n\n

这是“澄清”的代码:

\n\n
#include <linux/module.h>\n#include <net/sock.h>\n#include <linux/netlink.h>\n#include <linux/skbuff.h>\n#include <linux/string.h>\n#include <net/netlink.h>\n#include <net/genetlink.h>\n\nstruct sock *nl_sk = NULL;\n\nstatic void daemon(void){\n        struct sk_buff *skb;\n        void* msg_head;\n        unsigned char *msg;\n\n        struct genl_family my_genl_family = {\n                .id = GENL_ID_GENERATE,\n                .hdrsize = 0,\n                .name = "family_name",\n                .version = 1,\n                .maxattr = 5\n        };\n\n        struct genl_multicast_group my_mc_group = {\n                .name = "mc_group",\n        };\n\n\n        msg = "TEST";\n        skb = genlmsg_new(NLMSG_GOODSIZE, …
Run Code Online (Sandbox Code Playgroud)

c multicast kernel-module linux-kernel netlink

5
推荐指数
2
解决办法
3858
查看次数

为什么我无法使用 UPnP 单播 M-SEARCH 来代替 MultiCast M-SEARCH?

早上好,

我们决定尽可能使用 UPnP。我们在 239.255.255.250:1900 上使用 MultiCast 进行 M-SEARCH。

不过,我们正在研究如何处理客户在其网络上锁定 MultiCast 的情况。查看 UPnP 1.1 规范,它讨论了使用带有 M-SEARCH 的单播。因此,如果我们已经知道要与之通信的各种设备的 IP 地址,并且它们正在侦听 0.0.0.0:1900,则我们认为可以向 deviceIP:1900 上的每个设备发送单播 M-SEARCH。

我一直在尝试这样做,并且在让设备接收并响应单播 M-SEARCH 请求方面花费了很大的时间。

首先,是否允许您与设备的第一次 UPnP 对话以单播 M-SEARCH 开始?

其次,是否有某种原因导致在 0.0.0.0:1900 上监听不接受发送到 deviceIP:1900 的消息?

当我在计算机上执行 netstat 以查看正在使用的 IP 和端口时,似乎 239.255.255.250:1900 不在列表中,或者显示为 0.0.0.0:1900。

那么,如果 0.0.0.0 是 (ANY_IP),那么在 0.0.0.0:1900 上侦听的单个侦听器是否足以接收多播到 239.255.255.250:1900 的任何消息以及通过单播直接发送到该计算机的 ip:1900 的任何消息?

测试时,我总是能够收到多播,但我从未收到 M-SEARCH 的单播。在执行 GET 等操作时,我能够与其他端口上的设备进行通信,但似乎我无法让端口 1900 响应单播 M-SEARCH。

您实际上可以在同一台计算机上同时以多播方式侦听 239.255.255.250:1900 并以单播方式侦听 0.0.0.0:1900 而不发生 udp 套接字冲突吗?

对此的任何建议和指示将不胜感激。

谢谢,柯蒂斯

PS:我正在使用的代码如下。对于构造函数中的地址,我们传入 IPAddress.Any(即 0.0.0.0),Protocol.Port 为 1900。这在 Windows 8.1 下的 Windows 计算机上运行: …

udp multicast upnp udpclient

5
推荐指数
1
解决办法
3447
查看次数

Openwrt 允许多播流量

我在设备上运行 openwrt,并有一个 python 脚本,用于侦听和打印以屏幕 239.2.1.1 上的多播流量。

但是,屏幕上没有打印任何内容,我相信这是防火墙问题。如何确保运行 openwrt 的 LAN 接口允许多播流量?

linux multicast multicastsocket

5
推荐指数
1
解决办法
1万
查看次数

在Golang中,如何接收绑定到特定地址/端口的套接字的多播数据包?

手头的任务是将套接字专门绑定到地址 1.0.0.2:520(分配给 eth2),然后读取寻址到 224.0.0.9:520 的多播 UDP 数据包。

我正在尝试下面的代码,基于https://godoc.org/golang.org/x/net/ipv4

不幸的是,结果是永远不会到达此调试消息:log.Printf("udpReader: recv %d bytes from %s to %s on %s", n, cm.Src, cm.Dst, ifname)

我知道 eth2 正在接收所需的数据包,因为我在其上运行了数据包嗅探器:

sudo tcpdump -n -i eth2
18:40:28.571456 IP 1.0.0.1.520 > 224.0.0.9.520: RIPv2, Request, length: 24
18:40:29.556503 IP 1.0.0.1.520 > 224.0.0.9.520: RIPv2, Response, length: 64
Run Code Online (Sandbox Code Playgroud)

这是示例代码。你能看出为什么它不起作用吗?

package main

import (
    "fmt"
    "log"
    "net"

    "golang.org/x/net/ipv4"
)

func main() {
    if err := interfaceAdd("eth2"); err != nil {
        log.Printf("main: error: %v", err)
    }

    log.Printf("main: waiting forever")
    <-make(chan …
Run Code Online (Sandbox Code Playgroud)

sockets ip multicast go

5
推荐指数
1
解决办法
1万
查看次数

偶尔出现 java.io.IOException:仅在 Android 7.0 上不允许通过 DatagramSocket.send() 进行操作

以下代码在所有 Android 设备 Android 7.0 上几乎 100% 运行良好:

DatagramSocket clientSocket = new DatagramSocket();
clientSocket.setSoTimeout(4000);
clientSocket.setReuseAddress(true);        
clientSocket.setBroadcast(true);
...
DatagramPacket dpSend = new DatagramPacket(baSendData, baSendData.length, InetAddress.getByName("239.255.255.250"), 3702);
clientSocket.send(dpSend);
Run Code Online (Sandbox Code Playgroud)

在 Android 7.0 上,仅在 Android 7.0 上,clientSocket.send(dpSend) 偶尔会生成以下错误。我想强调“偶尔”。大多数时候它工作得很好。

我想知道是否有人可以提供对 Android 7.0 的任何见解,以阐明为什么异常仅发生在 Android 7.0 上。

sockets multicast datagram multicastsocket android-7.0-nougat

5
推荐指数
0
解决办法
858
查看次数

如何在 Android 中使用 mDNS 从“.local”解析 Ipv4 和 Ipv6

我正在尝试使用多播 DNS 从“.local”解析 IPv4 和 IpV6,我尝试了https://github.com/posicks/mdnsjava但它无法解析所需的 ipv4/ipv6。或者,我找到了一个适合我的应用程序,但不知道它是如何工作的。

应用程序链接: https://play.google.com/store/apps/details? id=com.dokoden.dotlocalfinder

另外,我尝试使用Linux“终端 -
用于解析 ipv4 的命令”用于 avahi-resolve-host-name abc.local -4
解析 ipv6 的命令来解析 “.local” avahi-resolve-host-name abc.local -6
,并且已成功解析。

我在 Android 中尝试了相同的命令来解析“.local”,但得到Cannot run program “avahi-resolve-host-name”: error=13, Permission returned

我正在 Android 中尝试这段代码 -

  Process process = Runtime.getRuntime().exec("avahi-resolve-host-name abc.local -4");
  BufferedReader in = new BufferedReader(new InputStreamReader(process.getInputStream()));
  Log.d("OutPut",in.readLine());
Run Code Online (Sandbox Code Playgroud)

android mdns multicast ipv4 ipv6

5
推荐指数
1
解决办法
2982
查看次数

VPC 内容器之间的 AWS ECS Fargate udp 多播

我想在同一 VPC 内的 ECS Fargate 上部署 udp 多播发送器和接收器。我遵循 Transit gateway 多播指令,但似乎仅适用于 EC2。

我想知道 ECS Fargate 是否支持组播?

AWS 提到

非 Nitro 实例不能作为多播发送者

Fargate默认使用非Nitro实例吗?或者它是可配置的吗?

非常感谢您的帮助,谢谢

multicast amazon-web-services amazon-ecs amazon-vpc aws-fargate

5
推荐指数
1
解决办法
736
查看次数

golang在多播ip上发送json

我正在写一个Go来发送多播udp上的json数据:

func send(a string, messages chan interface{}) {
    addr, err := net.ResolveUDPAddr("udp", a)
    CheckError(err)
    c, err := net.DialUDP("udp", nil, addr)
    CheckError(err)
    for {
        msg := <-messages
        myjson, err := json.Marshal(msg)
        if err != nil {
            fmt.Println("Error encoding JSON")
        return
        }
        //Write to bytes to multicast UDP
        c.Write([]byte(myjson))

        time.Sleep(2 * time.Second)
    }
}
Run Code Online (Sandbox Code Playgroud)

所以我的json被转换为一个byte数组,以使其工作.这是我的"接收器"功能:

func serveMulticastUDP(a string, messages chan interface{}) {

    addr, err := net.ResolveUDPAddr("udp", a)
    CheckError(err)
    l, err := net.ListenMulticastUDP("udp", nil, addr)
    l.SetReadBuffer(maxDatagramSize)
    for {
        b := make([]byte, maxDatagramSize)
        n, …
Run Code Online (Sandbox Code Playgroud)

arrays json multicast go gorilla

4
推荐指数
1
解决办法
745
查看次数